Android开发经验谈Android技术知识Android开发

Kotlin协程【基本使用与分析】

2020-05-06  本文已影响0人  hahaoop

协程的作用

官方描述:协程通过将复杂性放入库来简化异步编程。程序的逻辑可以在协程中顺序地表达,而底层库会为我们解决其异步性。该库可以将用户代码的相关部分包装为回调、订阅相关事件、在不同线程(甚至不同机器)上调度执行,而代码则保持如同顺序执行一样简单。kotlin 官方中文详细文档

协程最大的作用就是切换线程。Rxjava也可以线程切换,所以协程与Rxjava切换线程类似的,Rxjava切换是线程,而Kotlin的协程与Rxjava是不同的,协程和线程又有不同的,一个协程是一块块,每一块都有一个上下文Context,通过上下文做桥接来切换。

比如:有A线程和B线程,有三个代码块C1、C2、C3,这些代码块在执行时,在那个线程(A线程或B线程)上切换呢,那么就由协程去控制了,如A线程执行C1、C2代码块,B线程执行C3代码块。执行的单元以协程上下文Context,这么一块一块为单位来切换的。

可以简单地理解为,协程封装好一块块的代码在线程上执行,如封装好的一块块执行单元C1、C2在A线程上,如果要切换到B线程上,那么C1或C2的结果就以条件参数方式传入到C3中在B线程上执行。

协程的使用

1、添加依赖

//协程相关的核心库
  implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.2'
  implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.2'

2、创建协程

在 kotlin 里面提供了大量的高阶函数,kotlin 中 GlobalScope 类提供了几个携程构造函数。
runBlocking - 不是 GlobalScope 的 API,可以独立使用,区别是 runBlocking 里面的 delay 会阻塞线程,而 launch 创建的不会。
launch- 创建协程。
async - 创建带返回值的协程,返回的是 Deferred 类。
withContext - 不创建新的协程,在指定协程上运行代码块。

kotlin 在 1.3 之后要求协程必须由 CoroutineScope 创建,CoroutineScope 不阻塞当前线程,在后台创建一个新协程,也可以指定协程调度器。

3、runBlocking:T

class MainActivity : AppCompatActivity(){
  override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_main)
    tv_name.text = "learning kotlin"

    Log.e("lu","主线程——${Thread.currentThread().name}_id_${Thread.currentThread().id}")
    test()
    Log.e("lu","协程执行结束。")
}
  private fun test() = runBlocking {
    //循环10次
    repeat(10){
        Log.e("lu","协程执行$it——${Thread.currentThread().name}_id_${Thread.currentThread().id}")
        //挂起2秒
        delay(2000)
        }
      }
  }
  打印的结果
E/lu: 主线程——main_id_1
E/lu: 协程执行0——main_id_1
E/lu: 协程执行1——main_id_1
E/lu: 协程执行2——main_id_1
E/lu: 协程执行3——main_id_1
E/lu: 协程执行4——main_id_1
E/lu: 协程执行5——main_id_1
E/lu: 协程执行6——main_id_1
E/lu: 协程执行7——main_id_1
E/lu: 协程执行8——main_id_1
E/lu: 协程执行9——main_id_1
E/lu: 协程执行结束。

得出结论:

runBlocking启动的协程任务会阻断当前线程,直到该协程执行结束。当协程执行结束之后,页面才会被显示出来。

4、launch:Job

   class MainActivity : AppCompatActivity(){
   override fun onCreate(savedInstanceState: Bundle?) {
   super.onCreate(savedInstanceState)
   setContentView(R.layout.activity_main)
   tv_name.text = "learning kotlin"
​
   Log.e("lu","主线程——${Thread.currentThread().name}_id_${Thread.currentThread().id}")
  //        test()
   var job = GlobalScope.launch {
   //挂起5秒
   delay(5_000)
   Log.e("lu","协程执行——${Thread.currentThread().name}_id_${Thread.currentThread().id}")
   }
   Log.e("lu","主线程执行结束。")

   //另一种写法   指定调度器
   Log.e("lu","主线程——${Thread.currentThread().name}_id_${Thread.currentThread().id}")
  //        test()
   var job = GlobalScope.launch(Dispatchers.Unconfined) {
   //挂起5秒
   delay(5_000)
   Log.e("lu","协程执行——${Thread.currentThread().name}_id_${Thread.currentThread().id}")
   }
   Log.e("lu","主线程执行结束。")

   }
  }
    打印的结果
 E/lu: 主线程——main_id_1
 E/lu: 主线程执行结束。
 E/GED: Failed to get GED Log Buf, err(0)
 E/lu: 协程执行——DefaultDispatcher-worker-1_id_2664

launch:Job是最常用的用于启动协程的方式,它最终返回一个Job类型的对象,这个对象实际上是一个接口,它包涵了许多我们常用的函数和变量。

  //Job中的常用方法
  job.isActive//是否激活
  job.isCancelled//是否取消
  job.isCompleted//是否完成
  job.start()//启动协程,除了LAZY模式,协程都不需要手动启动
  job.cancel()//调用取消函数,取消一个协程
  job.join()//阻塞,直到某个协程执行完毕
  job.cancelAndJoin()//等待协程执行完毕,然后再取消

得出结论:

从执行结果看出,launch不会阻断主线程。

5、async

 class MainActivity : AppCompatActivity(){
 override fun onCreate(savedInstanceState: Bundle?) {
   super.onCreate(savedInstanceState)
   setContentView(R.layout.activity_main)
   tv_name.text = "learning kotlin"
   GlobalScope.launch {
       var result1 = GlobalScope.async {
           getResult1()
       }
       var result2 = GlobalScope.async {
           getResult2()
       }

       var result = result1.await()+result2.await();
       Log.e("lu","result——${result}")
   }
 }

 private suspend fun getResult1():String{
   delay(3_000)
   return "返回结果1"
 }
 private suspend fun getResult2():String{
   delay(3_000)
   return "返回结果2"
 }
 }
打印的结果
E/lu: result——返回结果1返回结果2
E/lu: 执行时间 3 秒

async跟launch的用法基本一样,区别在于:async的返回值类型是Deferred<T>,将最后一个封装成了该对象。async可以支持并发,此时一般都跟await一起使用。

得出结论:

async是不阻塞线程的,也就是说getResult1和getResult2是同时进行的,所以获取到result的时间是3s,而不是6s。

async 返回的是 Deferred 类型,Deferred 继承自 Job 接口,Job有的它都有,增加了一个方法 await ,这个方法接收的是 async 闭包中返回的值,async 的特点是不会阻塞当前线程,但会阻塞所在协程,也就是挂起。

注意:async 并不会阻塞线程,只是阻塞锁调用的协程。

上一篇下一篇

猜你喜欢

热点阅读