Kotlin中协程的创建过程详析
作者:ZzT 发布时间:2023-11-27 07:45:16
为什么需要协程?
协程可以简化异步编程,可以顺序地表达程序,协程也提供了一种避免阻塞线程并用更廉价、更可控的操作替代线程阻塞的方法 – 挂起函数。
Kotlin 的协程是依靠编译器实现的, 并不需要操作系统和硬件的支持。编译器为了让开发者编写代码更简单方便, 提供了一些关键字(例如suspend), 并在内部自动生成了一些支持型的代码。
创建并启动协程
fun create.main() {
//1. 创建协程体
val coroutine = suspend {
println("in coroutine")
5
}.createCoroutine(object: Continuation<Int> {
override fun resumeWith(result: Result<Int>) {
println("coroutine end: $result")
}
override val context: CoroutineContext
get() = EmptyCoroutineContext
})
//2. 执行协程
coroutine.resume(Unit)
}
上面代码的输出结果:
in coroutine
coroutine end: Success(5)
协程的执行过程
调用栈流程如下
我们通过 suspend block#createCoroutine 得到的 coroutine 实际是 SafeContinuation 对象
SafeContinuation 实际上是代理类,其中的 delegate 属性才是真正的 Continuation 对象
suspend block 中的代码在 BaseContinuationImpl 中执行
我们的匿名内部类对象 Continuation 被回调
suspend block 是如何变为协程体被执行的?
我们分析调用栈得知,resumeWith 最终是在 BaseContinuationImpl 中执行的,下面来看看代码
@SinceKotlin("1.3")
internal abstract class BaseContinuationImpl(
public val completion: Continuation<Any?>?
) : Continuation<Any?>, CoroutineStackFrame, Serializable {
public final override fun resumeWith(result: Result<Any?>) {
var current = this
var param = result
while (true) {
probeCoroutineResumed(current)
with(current) {
val completion = completion!!
val outcome: Result<Any?> =
try {
val outcome = invokeSuspend(param) //1.这里执行了 suspend block
if (outcome === COROUTINE_SUSPENDED) return
Result.success(outcome)
} catch (exception: Throwable) {
Result.failure(exception)
}
releaseIntercepted()
if (completion is BaseContinuationImpl) {
current = completion
param = outcome
} else {
completion.resumeWith(outcome) //2.这里回调了我们的匿名内部类
return
}
}
}
}
protected abstract fun invokeSuspend(result: Result<Any?>): Any? //3. 抽象方法
}
在代码注释 1. 处,调用 current.invokeSuspend,执行了我们定义的协程体,证明 suspend block 其实是 BaseContinuationImpl 的子类
在 2. 处,协程体执行完毕后,我们的代码收到了完成回调
在 3. 处,可以发现 invokeSuspend 是个抽象方法,suspend block 就是这个方法的具体实现
下面我通过断点,进一步分析 suspend block 是通过哪个子类执行的。
可以看到 current 是名为 {文件}${方法}${变量}$1 格式的对象,证明 kotlin 编译器遇到 suspend 关键字后会帮我们生成一个 BaseContinuationImpl 的子类
那么,这个子类到底是什么呢?将 kt 编译为 .class 再通过 jadx 打开后,得到的 java 代码如下
public final class CreateCoroutineKt {
public static final void create.main() {
Continuation coroutine = ContinuationKt.createCoroutine(new CreateCoroutineKt$create.main$coroutine$1(null), new CreateCoroutineKt$create.main$coroutine$2());
Unit unit = Unit.INSTANCE;
Result.Companion companion = Result.Companion;
coroutine.resumeWith(Result.constructor-impl(unit));
}
}
final class CreateCoroutineKt$create.main$coroutine$1 extends SuspendLambda implements Function1<Continuation<? super Integer>, Object> {
int label;
CreateCoroutineKt$create.main$coroutine$1(Continuation<? super CreateCoroutineKt$create.main$coroutine$1> continuation) {
super(1, continuation);
}
@NotNull
public final Continuation<Unit> create(@NotNull Continuation<?> continuation) {
return new CreateCoroutineKt$create.main$coroutine$1(continuation);
}
@Nullable
public final Object invoke(@Nullable Continuation<? super Integer> continuation) {
return create(continuation).invokeSuspend(Unit.INSTANCE);
}
@Nullable
public final Object invokeSuspend(@NotNull Object obj) {
IntrinsicsKt.getCOROUTINE_SUSPENDED();
switch (this.label) {
case 0:
ResultKt.throwOnFailure(obj);
System.out.println((Object) "in coroutine"); //协程体的逻辑
return Boxing.boxInt(5);
default:
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
}
}
明显看出,kt 编译器帮助我们把 suspend 关键字变为了 SuspendLambda 的 子类,并重写了 invokeSuspend 方法,不难猜出 SuspendLambda 继承自 BaseContinuationImp
来源:https://androidzzt.github.io/2022/01/23/kt-coroutine-create/
猜你喜欢
- 原因:keySet其实是遍历了2次,一次是转为Iterator对象,另一次是从hashMap中取出key所对应的value。而entrySe
- 本文实例为大家分享了java字符串和数字转换工具的具体代码,供大家参考,具体内容如下package com.test.util;/** *
- 一 自定义异常/** * 自定义参数为null异常 */public class NoParamsException extends Exc
- C# DateTime与时间戳的相互转换,包括JavaScript时间戳和Unix的时间戳。1. 什么是时间戳首先要清楚JavaScript
- 影响排序效率的一般从3个方面比较:数据比较的次数,数据移动的次数,内存空间占用的大小。我们就冒泡排序、选择排序、插入排序、快速排序做一个总的
- Aop什么是Aop?AOP就是面向切面编程,通过预编译方式以及运行期间的 * 技术来实现程序的统一维护功能。什么是切面,我理解的切面就是两
- 前言之前探讨过的 sealed class 和 sealed interface 存在 module 的限制,但其主要用于密封 class
- 前言:文件的上传和下载在日常开发中很是常见,那么这一功能是如何实现的呢,下面我给大家介绍一下实现条件:1、需要一个form标签,method
- 1. 选择恰当的日志级别常见的日志级别有5种,分别是error、warn、info、debug、trace。日常开发中,我们需要选择恰当的日
- 详解Kotlin中的面向对象(二)在Kotlin中的面向对象(一)中,介绍了Kotlin类的相关操作,本文将在上文的基础上,继续介绍属性、接
- 本文实例讲述了C# WinForm控件对透明图片重叠时出现图片不透明的简单解决方法。分享给大家供大家参考,具体如下:在Winform中如果将
- 本文实例为大家分享了java实现简单的图书管理系统的具体代码,供大家参考,具体内容如下一、项目分布Book类: 定义了书的一些属性(书名,作
- 说明:曾经在网上看过花样繁多的分页,很多都号称如何通用,但很多时候往往不尽如人意:有在分页类中还加入URL地址信息的,有在分页类中还进行分页
- 组播的概念UDP信息传递的方式分三类,分别是单播 Unicast:客户端与服务器之间的点到点连接多播MultiCast:又称组播,是&
- package com.yswc.dao.sign;import java.io.BufferedReader;import java.io
- 1、这个方法在GpsNET.JT809Core里来源:https://www.cnblogs.com/cnsend/p/12197982.h
- 当我们对一些需要用到的资料进行整理时,会发现文件的内存占用很大,不过是下载或者存储,都不是很方便,这时候我们会想到把文件变成zip格式,即进
- SpringBoot默认的存放静态资源文件的位置是:注:SpringBoot中的src/main/resources/资源文件夹对应clas
- 生成随机数在现实中我们经常用到随机数,可怎么实现呢,且听小乔慢慢道来。在C语言中,我们一般使用 <stdlib.h> 头文件中的
- 前言对于信息的加密方式多种多样,之前为大家介绍了一种自己设计的加密方式,有兴趣的朋友可以欣赏一下,欢迎给予指点。今天为大家介绍一下对称加密方