Kotlin协程到底是如何切换线程的
随着kotlin在android开发领域越来越火,协程在各个项目中的应用也逐渐变得广泛
但是协程到底是什么呢?
协程其实是个古老的概念,已经非常成熟了,但大家对它的概念一直存在各种疑问,众说纷纷
有人说协程是轻量级的线程,也有人说kotlin协程其实本质是一套线程切换方案
显然这对初学者不太友好,当不清楚一个东西是什么的时候,就很难进入为什么和怎么办的阶段了
本文主要就是回答这个问题,主要包括以下内容
1.关于协程的一些前置知识
2.协程到底是什么?
3.kotlin协程的一些基本概念,挂起函数,cps转换,状态机等
以上问题总结为思维导图如下:
1. 前置知识
1.1 coroutinescope
到底是什么?
coroutinescope
即协程运行的作用域,它的源码很简单
可以看出coroutinescope
的代码很简单,主要作用是提供coroutinecontext
,协程运行的上下文
我们常见的实现有globalscope
,lifecyclescope
,viewmodelscope
等
1.2 globalscope
与viewmodelscope
有什么区别?
两者的代码都挺简单,从上面可以看出
1.globalscope
返回的为coroutinecontext
的空实现
2.viewmodelscope
则往coroutinecontext
中添加了job
与dispatcher
我们先来看一段简单的代码
上面两种scope
启动协程后,打印当前线程名是不同的,一个是线程池中的一个线程,一个则是主线程
这是因为viewmodelscope
在coroutinecontext
中添加了dispatchers.main.immediate
的原因
我们可以得出结论:协程就是通过dispatchers
调度器来控制线程切换的
1.3 什么是调度器?
从使用上来讲,调度器就是我们使用的dispatchers.main
,dispatchers.default
,dispatcher.io
等
从作用上来讲,调度器的作用是控制协程运行的线程
从结构上来讲,dispatchers
的父类是continuationinterceptor
,然后再继承于coroutinecontext
它们的类结构关系如下:
这也是为什么dispatchers
能加入到coroutinecontext
中的原因,并且支持+
操作符来完成增加
1.4 什么是拦截器
从命名上很容易看出,continuationinterceptor
即协程拦截器,先看一下接口
从上面可以提炼出两个信息
1.拦截器的key
是单例的,因此当你添加多个拦截器时,生效的只会有一个
2.我们都知道,continuation
在调用其continuation#resumewith()
方法,会执行其suspend
修饰的函数的代码块,如果我们提前拦截到,是不是可以做点其他事情?这就是调度器切换线程的原理
上面我们已经介绍了是通过dispatchers
指定协程运行的线程,通过interceptcontinuation
在协程恢复前进行拦截,从而切换线程
带着这些前置知识,我们一起来看下协程启动的具体流程,明确下协程切换线程源码具体实现
2. 协程线程切换源码分析
2.1 launch
方法解析
我们首先看一下协程是怎样启动的,传入了什么参数
总共有3个参数:
1.传入的协程上下文
2.coroutinstart
启动器,是个枚举类,定义了不同的启动方法,默认是coroutinestart.default
3.block
就是我们传入的协程体,真正要执行的代码
这段代码主要做了两件事:
1.组合新的coroutinecontext
2.再创建一个 continuation
2.1.1 组合新的coroutinecontext
从上面可以提炼出以下信息:
1.会将launch
方法传入的context
与coroutinescope
中的context
组合起来
2.如果combined
中没有拦截器,会传入一个默认的拦截器,即dispatchers.default
,这也解释了为什么我们没有传入拦截器时会有一个默认切换线程的效果
2.1.2 创建一个continuation
默认情况下,我们会创建一个standlonecoroutine
值得注意的是,这个coroutine
其实是我们协程体的complete
,即成功后的回调,而不是协程体本身
然后调用coroutine.start
,这表明协程开始启动了
2.2 协程的启动
接着调用coroutinestart
的start
来启动协程,默认情况下调用的是coroutinestart.default
经过层层调用,最后到达了:
这里就是协程启动的核心代码,虽然比较短,却包括3个步骤:
1.创建协程体continuation
2.创建拦截 continuation
,即dispatchedcontinuation
3.执行dispatchedcontinuation.resumewith
方法
2.3 创建协程体continuation
调用createcoroutineunintercepted
,会把我们的协程体即suspend block
转换成continuation
,它是suspendlambda
,继承自continuationimpl
createcoroutineunintercepted
方法在源码中找不到具体实现,不过如果你把协程体代码反编译后就可以看到真正的实现
详情可见:字节码反编译
2.4 创建dispatchedcontinuation
从上可以提炼出以下信息
1.interepted
是个扩展方法,最后会调用到continuationimpl.intercepted
方法
2.在intercepted
会利用coroutinecontext
,获取当前的拦截器
3.因为当前的拦截器是coroutinedispatcher
,因此最终会返回一个dispatchedcontinuation
,我们其实也是利用它实现线程切换的
4.我们将协程体的continuation
传入dispatchedcontinuation
,这里其实用到了装饰器模式
,实现功能的增强
这里其实很明显了,通过dispatchedcontinuation
装饰原有协程,在dispatchedcontinuation
里通过调度器处理线程切换,不影响原有逻辑,实现功能的增强
2.5 拦截处理
上面说到了启动时会调用dispatchedcontinuation
的resumecancellablewith
方法
这里面做的事也很简单:
1.如果需要切换线程,调用dispatcher.dispatcher
方法,这里的dispatcher
是通过coroutineconext
取出来的
2.如果不需要切换线程,直接运行原有线程即可
2.5.2 调度器的具体实现
我们首先明确下,coroutinedispatcher
是通过coroutinecontext
取出来的,这也是协程上下文作用的体现coroutinedispater
官方提供了四种实现:dispatchers.main
,dispatchers.io
,dispatchers.default
,dispatchers.unconfined
我们一起简单看下dispatchers.main
的实现
可以看到,其实就是用handler
切换到了主线程
如果用dispatcers.io
也是一样的,只不过换成线程池切换了
如上所示,其实就是一个装饰模式
1.调用coroutindispatcher.dispatch
方法切换线程
2.切换完成后调用dispatchedtask.run
方法,执行真正的协程体
3 delay
是怎样切换线程的?
上面我们介绍了协程线程调度的基本原理与实现,下面我们来回答几个小问题
我们知道delay
函数会挂起,然后等待一段时间再恢复。
可以想象,这里面应该也涉及到线程的切换,具体是怎么实现的呢?
dealy
的代码也很简单,从上面可以提炼出以下信息delay
的切换也是通过拦截器来实现的,内置的拦截器同时也实现了delay
接口
我们来看一个具体实现
1.可以看出,其实也是通过handler.postdelayed
实现延时效果的
2.时间到了之后,再通过resumeundispatched
方法恢复协程
3.如果我们用的是dispatcher.io
,效果也是一样的,不同的就是延时效果是通过切换线程实现的
4. withcontext
是怎样切换线程的?
我们在协程体内,可能通过withcontext
方法简单便捷的切换线程,用同步的方式写异步代码,这也是kotin
协程的主要优势之一
可以看出这段代码做了一个切换线程然后再切换回来的操作,我们可以提出两个问题
1.withcontext
是怎样切换线程的?
2.withcontext
内的协程体结束后,线程怎样切换回到dispatchers.main
?
这段代码其实也很简单,可以提炼出以下信息
1.withcontext
其实就是一层api
封装,最后调用到了startcoroutinecancellable
,这就跟launch
后面的流程一样了,我们就不继续跟了
2.传入的context
会覆盖外层的拦截器并生成一个newcontext
,因此可以实现线程的切换
3.dispatchedcoroutine
作为complete
传入协程体的创建函数中,因此协程体执行完成后会回调到aftercompletion
中
4.dispatchedcoroutine
中传入的ucont
是父协程,它的拦截器仍是外层的拦截器,因此会切换回原来的线程中
总结
本文主要回答了kotlin
协程到底是怎么切换线程的这个问题,并对源码进行了分析
简单来讲主要包括以下步骤:
1.向coroutinecontext
添加dispatcher
,指定运行的协程
2.在启动时将suspend block
创建成continuation
,并调用intercepted
生成dispatchedcontinuation
3.dispatchedcontinuation
就是对原有协程的装饰,在这里调用dispatcher
完成线程切换任务后,resume
被装饰的协程,就会执行协程体内的代码了
其实kotlin
协程就是用装饰器模式实现线程切换的
看起来似乎有不少代码,但是真正的思路其实还是挺简单的,这大概就是设计模式的作用吧
最后
小编分享一些 android 开发相关的学习文档、面试题、android 核心笔记等等文档,希望能帮助到大家学习提升,如有需要参考的可以直接去我 codechina地址:https://codechina.csdn.net/u012165769/android-t3 访问查阅。如果本文对你有所帮助,欢迎点赞收藏~
到此这篇关于kotlin协程到底是如何切换线程的的文章就介绍到这了,更多相关协程切换线程内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!