java程序员的kotlin课(N):coroutines基础

序言

如果对协程没有概念,不了解使用协程的好处,请参考《异步编程
》系列文章

引入协程库

kotlin协程是以一个lib包的形式引入的,参考: kotlinx.coroutines

这里摘录gradle方式的协程库引入

dependencies {
    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.3'
}

请确认使用了最新版本的kotlin

buildscript {
    ext.kotlin_version = '1.3.61'
}

语法讲解

此部分翻译至 https://kotlinlang.org/docs/reference/coroutines/basics.html,作了微调

第一个协程程序

我们使用协程来写一个helloworld程序

fun main() {
    GlobalScope.launch { // 启动并后台运行一个协程
        delay(1000L) // 非阻塞的暂停1s
        println("World!") 
    }
    println("Hello,") // 主线程继续执行
    Thread.sleep(2000L) // 主线程睡眠2秒钟,保持当前jvm进程存活
}

输出:

Hello,
World!

本质上,协程是一种轻量级的线程。通过launch关键字启动,launch是一个协程构建器,携带一种CoroutineScope的上下文。上面的代码中,我们在Global Scope中启动了协程,这意味着,被启动的协程的生命周期与整个进程保持一致。
我们可以通过把GlobalScope.launch { ... }替换为thread { ... }并把delay(...)替换为Thread.sleep(...)来实现同样的效果(去试试吧!)
如果你把 GlobalScope.launch 替换为 thread(译者:还没来得及替换delay), 编译器会报如下的错:

Error: Kotlin: Suspend functions are only allowed to be called from a coroutine or another suspend function

这是因为delay是一个suspending function并不会阻塞线程但是会阻塞协程,而且他只能在协程中被调用。

阻塞和非阻塞世界的桥梁

上面的例子在同一段代码中混用了 non-blocking delay(...)blocking Thread.sleep(...) . 这样很容易让我们混淆哪些是blocking哪些不是blocking的代码. 让我们通过 runBlocking 协程构建器来提出阻塞的代码吧:

fun main() { 
    GlobalScope.launch { // 启动并在后台运行协程
        delay(1000L)
        println("World!")
    }
    println("Hello,") // 主线程直接继续执行
    runBlocking {     // 会阻塞主线程的执行
        delay(2000L)  // 保持jvm的持续运行
    } 
}

上面的代码执行结果是一样的,但是只用了非阻塞的delay。主线程执行了runBlocking代码块,并且主线程在其代码块内部执行完成之前会被阻塞。
上面例子里的代码可以被重写成更加通用的方式:

fun main() = runBlocking<Unit> { // 启动主协程
    GlobalScope.launch { // 启动新协程并在后台允许
        delay(1000L)
        println("World!")
    }
    println("Hello,") // 主协程此处直接继续执行
    delay(2000L)      // 睡两秒保持jvm运行
}

这里使用了runBlocking<Unit> { ... }作为一个适配器,用来在最顶层启动主协程,我们声明了Unit作为他的返回值类型,因为main函数需要如此。
这也是对suspending函数做单元测试的一种方法:

class MyTest {
    @Test
    fun testMySuspendingFunction() = runBlocking<Unit> {
        // here we can use suspending functions using any assertion style that we like
    }
}
等待一个任务的执行

上面几个例子里,都是通过主函数最后睡几秒来保持jvm进程的运行状态,这并不是很好,让我们来更精确的控制时间:

val job = GlobalScope.launch { //此处获得一个job的引用
    delay(1000L)
    println("World!")
}
println("Hello,")
job.join() // 主协程等待,直到job执行完毕

现在,执行结果依然相同,但代码好看多了!

结构化并发

如果想要在实际中使用协程,还需要考虑一些其他的事情。当我们使用GlobalScope.launch时,我们就创建了top-level的协程。虽然协程是轻量的,但协程运行时毕竟还是要消耗一些内存的。如果我们对新创建的协程没有保持引用,而协程恰巧hangs住了,如果我们跑了海量的协程并发生内存溢出...必须要手动管理已启动协程的引用,join 这些协程是容易出错的。
有更好的解决方案,我们可以在代码里使用结构化并发:基于当前操作的scope创建所需的协程,而不是使用GlobalScope
在我们的例子里我们的main函数通过runBlocking协程构建器转换成一个协程函数。包括runBlocking在内的每一个协程构造器都会给它对应的代码块附加一个CoroutineScope实例。

join

我们可以基于这个scope创建新的协程,而不需显示的join,因为外层的协程在这个scope内的所有协程介绍之前不会结束。所以我们可以让我们的例子更加简单:

fun main() = runBlocking { // this: CoroutineScope
    launch { // launch a new coroutine in the scope of runBlocking
        delay(1000L)
        println("World!")
    }
    println("Hello,")
}
scope构建器

上文讲到每一个协程构建器会自动创建一个自己的scope,这节给大家介绍一下我们可以通过coroutineScope自定义创建scope。scope的作用就是scope不会结束在scope内部代码和内部launch的所有协程结束之前。

fun main() = runBlocking { // this: CoroutineScope
    launch { 
        delay(200L)
        println("Task from runBlocking")
    }
    
    coroutineScope { // Creates a coroutine scope
        launch {
            delay(500L) 
            println("Task from nested launch")
        }
    
        delay(100L)
        println("Task from coroutine scope") // This line will be printed before the nested launch
    }
    
    println("Coroutine scope is over") // 在我们自定义的coroutineScope结束之前,这一行不会执行
}

输出

Task from coroutine scope
Task from runBlocking
Task from nested launch
Coroutine scope is over

runBlockingcoroutineScope 比较相似,因为他们都会等待内部代码块执行完毕也会等待其内部创建的协程执行完毕。区别是一个阻塞当前线程一个阻塞当前协程,所以他们一个是普通方法,一个是suspend方法。

方法拆分重构

原文这个章节的意思没理解透,只记录理解的部分:
当我们做代码拆分,把一部分代码单独拆分到另一个函数里时,被拆分出来的函数需要以suspend修饰,只有suspend修饰的函数才能在协程里被调用。

fun main() = runBlocking {
    launch { doWorld() }
    println("Hello,")
}

// this is your first suspending function
suspend fun doWorld() {
    delay(1000L)
    println("World!")
}

总结

coroutine builder
GlobalScope.launch {}
runBlocking
join
CoroutineScope
Scope Builder
suspend

系列文章快速导航:
java程序员的kotlin课(一):环境搭建
java程序员的kotlin课(N):coroutines基础
java程序员的kotlin课(N+1):coroutines 取消和超时
java程序员的kotlin课(N+2):suspending函数执行编排

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