Kotlin Primer·第七章·协程库(上篇)

本篇只讲了协程库的使用。还有中篇讲协程的启动和切换实现原理,下篇核心讲解kotlin协程在JVM层的实现原理。
这可能是至今为止最详细实用的 Kotlin 协程库详解了。

第一部分——快速上手
第一章·启程
第二章·基本语法
第三章·Kotlin 与 Java 混编
第二部分——开始学习 Kotlin
第四章·Kotlin 的类特性(上)
第四章·Kotlin 的类特性(下)
第五章·函数与闭包
第六章·集合泛型与操作符
第三部分——Kotlin 工具库
第七章·协程库(上篇)
第七章·协程库(中篇)

7.协程

协程,协作代码段。相对线程而言,协程更适合于用来实现彼此熟悉的程序组件。协程提供了一种可以避免线程阻塞的能力,这是他的核心功能。在 kotlin 中使用协程,需要在 gradle 中引入协程库:

//Android 工程使用
implementation "org.jetbrains.kotlinx:kotlinx-coroutines-android:x.x.x"  
//Java 工程使用
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:x.x.x'

7.1 协程是什么

协程的概念其实是很早就被提出的。
这里借用知乎作者阿猫的一段回答(有所修改)来为大家讲解协程究竟是怎么来的:

  1. 一开始大家想要同一时间执行多个代码任务,于是就有了并发。从程序员的角度可以看成是多个独立的逻辑流,内部可以是多 CPU 并行,也可以是单 CPU 时间分片。
  2. 但是一并发就有上下文切换的问题,干了一半跑去处理另一件事,我这做了一半的东西怎么保存。进程就是这样抽象出来个一个概念,搭配虚拟内存、进程表之类,用来管理独立的程序运行、切换。
  3. 后来硬件提升了,一电脑上有了好几个 CPU 就可以一人跑一进程,就是所谓的并行
  4. 但是一并行,进程数一高,大部分系统资源就得用于进程切换的状态保存。后来搞出线程的概念,大致意思就是这个地方阻塞了,但我还有其他地方的逻辑流可以计算,不用特别麻烦的切换页表、刷新 TLB,只要把寄存器刷新一遍就行。
  5. 如果你嫌操作系统调度线程有不确定性,不知道什么时候开始什么时候切走,我自己在进程里面手写代码去管理逻辑调度这就是用户态线程
  6. 而用户态线程是不可剥夺的,如果一个用户态线程发生了阻塞,就会造成整个进程阻塞,所以进程需要自己拥有调度线程的能力。而如果用户态线程将控制权交给进程,让进程调度自己,这就是协程

后来我们的内存越来越大,操作系统的调度也越来越智能,就慢慢没人再去花时间去自己实现用户态线程、协程这些东西了。

7.2 为什么又要用协程了

那既然上面说协程已经淘汰在历史的长河中了,为什么现在又跑来这么声势浩大。
这就要从多线程的效率讲起了。
前面我们讲由于操作系统的多线程调度越来越智能,硬件设备也越来越好,这大幅提升了线程的效率,因此正常情况下线程的效率是高于协程的,而且是远高于协程。
那么线程在什么情况下效率是最高的?就是在一直 run 的情况下。但是线程几乎是很难一直 run 的,比如:线程上下文切换、复杂计算阻塞、IO阻塞。
于是又有人想起了协程,这个可以交给代码调度的东西。

7.3 kotlin 的协程怎么用

在 kotlin 上,使用协程你只需要知道两个方法和他们的返回类型,就可以很熟练的用上协程了。分别是:

fun launch(): Job
fun async(): Deferred

7.3.1 launch方法

从方法名我们就能看出,launch表示启动一个协程。

public fun launch(
    context: CoroutineContext,
    start: CoroutineStart = CoroutineStart.DEFAULT,
    block: suspend CoroutineScope.() -> Unit
): Job {
}

launch()方法接收三个参数,通常很少用到第二个参数。
第一个参数是一个协程的上下文,CoroutineContext不仅可以用于在协程跳转的时刻传递数据,同时最主要的功能,是用于表明协程运行与恢复时的上下文环境。
通常Android在用的时候都是传一个UI就表示在 UI 线程启动协程,或者传一个CommonPool表示在异步启动协程,还有一个是Unconfined表示不指定,在哪个线程调用就在哪个线程恢复。

fun test() {
    launch(UI) {
        val isUIThread = Thread.currentThread() == Looper.getMainLooper().thread
        println("UI::===$isUIThread")
    }
    launch(CommonPool) {
        val isUIThread = Thread.currentThread() == Looper.getMainLooper().thread
        println("CommonPool::===$isUIThread")
    }
}

例如这段代码就会输出一个

UI::===true
CommonPool::===false

7.3.2 Job对象

launch()方法会返回一个job对象,job对象常用的方法有三个,叫startjoincancel。分别对应了协程的启动、切换至当前协程、取消。

例如下面是start()方法的使用示例:

fun test() {
    //当启动类型设置成LAZY时,协程不会立即启动,而是手动调用start()后他才会启动。
    val job = launch(UI, CoroutineStart.LAZY) {
        println("hello")
    }
    job.start()
}

join()方法就比较特殊,他是一个suspend方法。suspend 修饰的方法(或闭包)只能调用被suspend修饰过的方法(或闭包)。 方法声明如下:

public suspend fun join()

因此,join()方法只能在协程体内部使用,跟他的功能:切换至当前协程所吻合。

fun test() {
    val job1 = launch(UI, CoroutineStart.LAZY) {
        println("hello1")
    }
    val job2 = launch(UI) {
        println("hello2")
        job1.join()
        println("hello3")
    }
}

这段代码执行后将会输出

hello2
hello1
hello3

7.3.3 async()方法

async()方法也是创建一个协程并启动,甚至连方法的声明都跟launch()方法一模一样。
不同的是,async()方法的返回值,返回的是一个Deferred对象。这个接口是Job接口的子类。
因此上文介绍的所有方法,都可以用于Deferred的对象。

Deferred最大的用处在于他特有的一个方法await()

public suspend fun await(): T

await()可以返回当前协程的执行结果,也就是你可以这样写代码:

fun test() {
    val deferred1 = async(CommonPool) {
        "hello1"
    }
    val deferred2 = async(UI) {
        println("hello2")
        println(deferred1.await())
    }
}

你发现神奇的地方了吗,我让一个工作在主线程的协程,获取到了一个异步协程的返回值。
这意味着,我们以后网络请求、图片加载、数据库、文件操作什么的,都可以丢到一个异步的协程中去,然后在同步代码中直接取返回值,而不再需要去写回调了。
这就是我们经常使用的一个最大特性。

7.4 kotlin 协程使用示例

最后用一个稍微复杂一点的例子,来讲 kotlin 协程的使用

fun test() {
    //每秒输出两个数字
    val job1 = launch(Unconfined, CoroutineStart.LAZY) {
        var count = 0
        while (true) {
            count++
            //delay()表示将这个协程挂起500ms
            delay(500)
            println("count::$count")
        }
    }
    
    //job2会立刻启动
    val job2 = async(CommonPool) {
        job1.start()
        "ZhangTao"
    }

    launch(UI) {
        delay(3000)
        job1.cancel()
        //await()的规则是:如果此刻job2已经执行完则立刻返回结果,否则等待job2执行
        println(job2.await())
    }
}

最终输出了6次,job1 就被 cancel 了

count::1
count::2
count::3
count::4
count::5
count::6
ZhangTao
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,271评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,275评论 2 380
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,151评论 0 336
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,550评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,553评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,559评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,924评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,580评论 0 257
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,826评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,578评论 2 320
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,661评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,363评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,940评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,926评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,156评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,872评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,391评论 2 342

推荐阅读更多精彩内容