Kotlin协程探索 (一)(Coroutine)
PS:以下协程都特指Kotlin协程;且期望大家大概知道协程的写法;
- 什么是协程?
- 协程?线程?优势?
什么是协程?
引用官方的话就是
本质上,协程是轻量级的线程。 它们在某些 CoroutineScope 上下文中与 launch 协程构建器 一起启动。 这里我们在 GlobalScope 中启动了一个新的协程,这意味着新协程的生命周期只受整个应用程序的生命周期限制。
可以将 GlobalScope.launch { …… } 替换为 thread { …… },并将 delay(……) 替换为 Thread.sleep(……) 达到同样目的。 试试看(不要忘记导入 kotlin.concurrent.thread)。
个人看法
协程是线程内自主可控的任务集,不需要等待系统切换线程进行调度,从而轻量化线程的操作,请看下图
协程?线程?优势?
栗子,最基本样子,没什么可比性
fun main(args: Array<String>) = runBlocking<Unit> {
thread {
println("开启一个线程")
}
launch {
println("开启一个协程")
}
}
继续,当出现耗时操作,由于Kotlin协程内部使用线程池,为了公平起见,有了以下两个栗子
- 线程
fun main(args: Array<String>) = runBlocking<Unit> {
//4个线程
time { //统计运行时间
val threadPool = Executors.newScheduledThreadPool(4)
repeat(100) {
threadPool.submit {
Thread.sleep(500)
println("thread println $it")
}
}
threadPool.shutdown()
threadPool.awaitTermination(100, TimeUnit.SECONDS)
}.println()
}
- 协程
fun main(args: Array<String>) = runBlocking<Unit> {
//4个线程
time { //统计运行时间
runBlocking {
val dispatcher = newFixedThreadPoolContext(4, "CoroutineThreadPoolDispatcher")
repeat(100) {
launch(dispatcher) {
delay(500)
println("coroutine println $it")
}
}
}
}.println()
}
惊不惊喜?意不意外?
同样4个线程,同样100个任务,同样每个任务耗时500毫秒,线程池运行12秒,协程运行0.5秒
What?为什么会这样?
原因就在于协程的优势
这里涉及到一个协程概念,非阻塞式挂起
这是什么意思呢?
就是当协程任务挂起时,不会阻塞协程的其他任务,也不会阻塞当前线程的运行,这就是非阻塞式挂起
栗子在上:过程分析
- 线程
提交了100个任务,线程池同时执行4个任务,每个任务都耗时500毫秒;导致线程阻塞,原地等待,使得剩余的96个任务需要等待前面的任务完成才能继续执行(剩余任务同理);理论运行时间计算 100 * 500 / 4 = 12500;即12秒左右
- 协程
提交了100个任务,线程池同时执行4个任务,每个任务都耗时500毫秒;
但是!!!协程任务可以进行非阻塞式挂起,这就导致了该任务没有阻塞其他协程任务,也没有阻塞线程,线程依然可以继续执行其他协程任务,这就影响了结果,因为100个任务几乎是时同时在等待500毫秒;理论运行时间计算 500 毫秒;即 0.5 秒左右
通过上面的例子&分析
协程对比于线程,可以更优的利用线程资源,从而达到更优的体验,更高的运行速率
优势?
方便,高效,优雅的异步
关于非阻塞式挂起
Kotlin协程的非阻塞式挂起是一种基于有限状态自动机来实现的一种技术,有兴趣的童鞋可以点击链接进行查看这是什么东东,这里不准备详谈