Android kotlin 协程篇

协程是什么

• 协程是一种在程序中处理并发任务的方案；也是这种方案的一个组件。
• 协程和线程属于一个层级的概念。

下面我们描述一个常见的场景 后台耗时操作 -> 前台刷新界面 -> 后台耗时操作 -> 前台刷新界面 等操作 就是来回切线程做操作

    ioCamp1() //后台耗时操作
    uiCamp1() //前台刷新界面
    ioCamp2() //后台耗时操作
    uiCamp2() //前台刷新界面

/**
        * kotion 协程 的做法。
        *
        * suspend : 挂起函数，只起标记作用，实际没有作用
        *    并不是用来切线程的
        *    关键作用：标记和提醒
        *
        *
        * Dispatchers.Main：指定线程
        * 用 launch（）来开启一段协程 一般需要指定Dispatchers.Main
        * 把要在后台工作的函数，写成supend函数，需要在内部调用其他suspend函数真正切换线程
        *
        * 协程提高软件性能
        * 程序什么时候需要切换线程
        *  1.工作比较耗时：放在后台
        *      a）怎么判断函数是否耗时
        *      b）如何使用协程规避这个问题 --- 写的时候把该函数写成挂起函数。
        *  2.工作比较特殊：放在指定线程 -- 一般是主线程（譬如更新ui）
        *
        * 亮点1：耗时函数自动后台，从而提高性能。
        * 亮点2：线程的自动切回
        *
        * 协程提供了挂起函数所需要的上下文信息。
        */

       GlobalScope.launch(Dispatchers.Main) {
           ioCamp1()
           uiCamp1()
           ioCamp2()
           uiCamp2()
       }
   private suspend fun ioCamp1() {
       withContext(Dispatchers.IO) { //挂起函数，切换到子线程
      Log.e("Coroutines", "io1:${Thread.currentThread().name}")
       }
   }

   private fun uiCamp1() {
       tvTextview1.text = strValue
       Log.e("Coroutines", "ui1:${Thread.currentThread().name}")
   }

   private suspend fun ioCamp2() {
       withContext(Dispatchers.IO) { //挂起函数，切换到子线程
           Log.e("Coroutines", "io2:${Thread.currentThread().name}")
       }
   }

private fun uiCamp2() {
       Log.e("Coroutines", "ui2:${Thread.currentThread().name}")
   }

       ---------------------------请求单个接口-----------------------
        /**
         *  retrofit对协程的写法
         */
        val retrofit = Retrofit.Builder()
            .baseUrl("https://api.github.com/")
            .addConverterFactory(GsonConverterFactory.create())
            .build()
        val api = retrofit.create(Api::class.java)
        GlobalScope.launch(Dispatchers.Main) {
            try {
                val repos = api.listReposKt("sgl890226") // 后台
                tvTextview1.text = repos[0].name // 前台
            } catch (e: Exception) {
                tvTextview1.text = e.message // 前台
            }
        }
 ---------------------------请求多个接口，需要合并数据-----------------------
   /**
         * 协程 的写法
         */
        //使用该方式记得destory 取消当前任务，防止内测泄露
        job =  GlobalScope.launch(Dispatchers.Main) {
            val one = async { api.listReposKt("sgl890226") }
            val two = async { api.listReposKt("google") }
            tvTextview1.text = "${one.await()[0].name} -> ${two.await()[0].name}"
        }
        // 使用该方式不需要destory取消当前任务，android帮我们做了。
        lifecycleScope.launchWhenCreated {
            val one = async { api.listReposKt("sgl890226") }
            val two = async { api.listReposKt("google") }
            tvTextview2.text = "${one.await()[0].name} -> ${two.await()[0].name}"
        }

可直接下载源码，源码里面注释更详细
源代码：https://github.com/sgl890226/Coroutinesscamp

参考：https://zhuanlan.zhihu.com/p/312262443