Android Kotlin 协程初探 | 京东物流技术团队

news2025/1/12 23:04:56

1 它是什么（协程 和 Kotlin协程）

1.1 协程是什么

维基百科：协程，英文Coroutine [kəru’tin] （可入厅），是计算机程序的一类组件，推广了协作式多任务的子程序，允许执行被挂起与被恢复。

作为Google钦定的Android开发首选语言Kotlin，协程并不是 Kotlin 提出来的新概念，目前有协程概念的编程语言有Lua语言、Python语言、Go语言、C语言等，它只是一种编程思想，不局限于特定的语言。

而每一种编程语言中的协程的概念及实现又不完全一样，本次分享主要讲Kotlin协程。

1.2 Kotlin协程是什么

Kotlin官网：协程是轻量级线程

可简单理解：一个线程框架，是全新的处理并发的方式，也是Android上方便简化异步执行代码的方式

类似于 Java：线程池 Android：Handler和AsyncTask，RxJava的Schedulers

注：Kotlin不仅仅是面向JVM平台的，还有JS/Native，如果用kotlin来写前端，那Koltin的协程就是JS意义上的协程。如果仅仅JVM 平台，那确实应该是线程框架。

1.3 进程、线程、协程比较

可通过以下两张图理解三者的不同和关系

2 为什么选择它（协程解决什么问题）

异步场景举例：

  1. 第一步：接口获取当前用户token及用户信息
  2. 第二步：将用户的昵称展示界面上
  3. 第三步：然后再通过这个token获取当前用户的消息未读数
  4. 第四步：并展示在界面上

2.1 现有方案实现

apiService.getUserInfo().enqueue(object :Callback<User>{
    override fun onResponse(call: Call<User>, response: Response<User>) {
        val user = response.body()
        tvNickName.text = user?.nickName
        apiService.getUnReadMsgCount(user?.token).enqueue(object :Callback<Int>{
            override fun onResponse(call: Call<Int>, response: Response<Int>) {
                val tvUnReadMsgCount = response.body()
                tvMsgCount.text = tvUnReadMsgCount.toString()
            }
        })
    }
})

现有方案如何拿到异步任务的数据，得不到就毁掉哈哈哈，就是通过回调函数来解决。
若嵌套多了，这种画风是不是有点回调地狱的感觉，俗称的「callback hell」

2.2 协程实现

mainScope.launch {
    val user = apiService.getUserInfoSuspend() //IO线程请求数据
    tvNickName.text = user?.nickName //UI线程更新界面
    val unReadMsgCount = apiService.getUnReadMsgCountSuspend(user?.token) //IO线程请求数据
    tvMsgCount.text = unReadMsgCount.toString() //UI线程更新界面
}

suspend fun getUserInfoSuspend() :User? {
    return withContext(Dispatchers.IO){
        //模拟网络请求耗时操作
        delay(10)
        User("asd123", "userName", "nickName")
    }
}

suspend fun getUnReadMsgCountSuspend(token:String?) :Int{
    return withContext(Dispatchers.IO){
        //模拟网络请求耗时操作
        delay(10)
        10
    }
}

红色框框内的就是一个协程代码块。

可以看得出在协程实现中告别了callback，所以再也不会出现回调地狱这种情况了，协程解决了回调地狱

协程可以让我们用同步的代码写出异步的效果，这也是协程最大的优势，异步代码同步去写。

小结：协程可以异步代码同步去写，解决回调地狱，让程序员更方便地处理异步业务，更方便地切线程，保证主线程安全。

它是怎么做到的？

3 它是怎么工作的（协程的原理浅析）

3.1 协程的挂起和恢复

挂起（非阻塞式挂起）

suspend 关键字，它是协程中核心的关键字，是挂起的标识。

下面看一下上述示例代码切换线程的过程：

每一次从主线程切到IO线程都是一次协程的挂起操作；

每一次从IO线程切换主线程都是一次协程的恢复操作；

挂起和恢复是suspend函数特有的能力，其他函数不具备，挂起的内容是协程，不是挂起线程，也不是挂起函数，当线程执行到suspend函数的地方，不会继续执行当前协程的代码了，所以它不会阻塞线程，是非阻塞式挂起。

有挂起必然有恢复流程， 恢复是指将已经被挂起的目标协程从挂起之处开始恢复执行。在协程中，挂起和恢复都不需要我们手动处理，这些都是kotlin协程帮我们自动完成的。

那Kotlin协程是如何帮我们自动实现挂起和恢复操作的呢？

它是通过Continuation来实现的。 [kənˌtɪnjuˈeɪʃ(ə)n] （继续；延续；连续性；后续部分）

3.2 协程的挂起和恢复的工作原理（Continuation）

CPS + 状态机

Java中没有suspend函数，suspend是Kotlin中特有的关键字，当编译时，Kotlin编译器会将含有suspend关键字的函数进行一次转换。

这种被编译器转换在kotlin中叫CPS转换（cotinuation-passing-style）。

转换流程如下所示

程序员写的挂起函数代码：

suspend fun getUserInfo() : User {
    val user = User("asd123", "userName", "nickName")
    return user
}

假想的一种中间态代码（便于理解）：

fun getUserInfo(callback: Callback<User>): Any? {
    val user = User("asd123", "userName", "nickName")
    callback.onSuccess(user)
    return Unit
}

转换后的代码：

fun getUserInfo(cont: Continuation<User>): Any? {
    val user = User("asd123", "userName", "nickName")
    cont.resume(user)
    return Unit
}

我们通过Kotlin生成字节码工具查看字节码，然后将其反编译成Java代码：

@Nullable
public final Object getUserInfo(@NotNull Continuation $completion) {
   User user = new User("asd123", "userName", "nickName");
   return user;
}

这也验证了确实是会通过引入一个Continuation对象来实现恢复的流程，这里的这个Continuation对象中包含了Callback的形态。

它有两个作用：1. 暂停并记住执行点位；2. 记住函数暂停时刻的局部变量上下文。

所以为什么我们可以用同步的方式写异步代码，是因为Continuation帮我们做了回调的流程。

下面看一下这个Continuation 的源码部分

可以看到这个Continuation中封装了一个resumeWith的方法，这个方法就是恢复用的。

internal abstract class BaseContinuationImpl() : Continuation<Any?> {


    public final override fun resumeWith(result: Result<Any?>) {
        //省略好多代码
        invokeSuspend()
        //省略好多代码
    }


    protected abstract fun invokeSuspend(result: Result<Any?>): Any?
}


internal abstract class ContinuationImpl(
    completion: Continuation<Any?>?,
    private val _context: CoroutineContext?
) : BaseContinuationImpl(completion) {

protected abstract fun invokeSuspend(result: Result<Any?>): Any?

//invokeSuspend() 这个方法是恢复的关键一步

继续看上述例子：

这是一个CPS之前的代码：

suspend fun testCoroutine() {
    val user = apiService.getUserInfoSuspend() //挂起函数  IO线程
    tvNickName.text = user?.nickName //UI线程更新界面
    val unReadMsgCount = apiService.getUnReadMsgCountSuspend(user?.token) //挂起函数  IO线程
    tvMsgCount.text = unReadMsgCount.toString() //UI线程更新界面
}

当前挂起函数里有两个挂起函数

通过kotlin编译器编译后：

fun testCoroutine(completion: Continuation<Any?>): Any? {
    // TestContinuation本质上是匿名内部类
    class TestContinuation(completion: Continuation<Any?>?) : ContinuationImpl(completion) {
        // 表示协程状态机当前的状态
        var label: Int = 0


        // 两个变量，对应原函数的2个变量
        lateinit var user: Any
        lateinit var unReadMsgCount: Int


        // result 接收协程的运行结果
        var result = continuation.result


        // suspendReturn 接收挂起函数的返回值
        var suspendReturn: Any? = null


        // CoroutineSingletons 是个枚举类
        // COROUTINE_SUSPENDED 代表当前函数被挂起了
        val sFlag = CoroutineSingletons.COROUTINE_SUSPENDED


        // invokeSuspend 是协程的关键
        // 它最终会调用 testCoroutine(this) 开启协程状态机
        // 状态机相关代码就是后面的 when 语句
        // 协程的本质，可以说就是 CPS + 状态机
        override fun invokeSuspend(_result: Result<Any?>): Any? {
            result = _result
            label = label or Int.Companion.MIN_VALUE
            return testCoroutine(this)
        }
    }


    // ...
    val continuation = if (completion is TestContinuation) {
        completion
    } else {
        //                作为参数
        //                   ↓
        TestContinuation(completion)

loop = true
while(loop) {
when (continuation.label) {
    0 -> {
        // 检测异常
        throwOnFailure(result)


        // 将 label 置为 1，准备进入下一次状态
        continuation.label = 1


        // 执行 getUserInfoSuspend（第一个挂起函数）
        suspendReturn = getUserInfoSuspend(continuation)


        // 判断是否挂起
        if (suspendReturn == sFlag) {
            return suspendReturn
        } else {
            result = suspendReturn
            //go to next state
        }
    }


    1 -> {
        throwOnFailure(result)


        // 获取 user 值
        user = result as Any


        // 准备进入下一个状态
        continuation.label = 2


        // 执行 getUnReadMsgCountSuspend
        suspendReturn = getUnReadMsgCountSuspend(user.token, continuation)


        // 判断是否挂起
        if (suspendReturn == sFlag) {
            return suspendReturn
        } else {
            result = suspendReturn
            //go to next state
        }
    }


    2 -> {
        throwOnFailure(result)


        user = continuation.mUser as Any
        unReadMsgCount = continuation.unReadMsgCount as Int
        loop = false
}
}

通过一个label标签控制分支代码执行,label为0,首先会进入第一个分支,首先将label设置为下一个分支的数值,然后执行第一个suspend方法并传递当前Continuation,得到返回值,如果是COROUTINE SUSPENDED,协程框架就直接return,协程挂起,当第一个suspend方法执行完成,会回调Continuation的invokeSuspend方法,进入第二个分支执行,以此类推执行完所有suspend方法。

每一个挂起点和初始挂起点对应的 Continuation 都会转化为一种状态，协程恢复只是跳转到下一种状态中。挂起函数将执行过程分为多个 Continuation 片段，并且利用状态机的方式保证各个片段是顺序执行的。

小结：协程的挂起和恢复的本质是CPS + 状态机

4 总结

总结几个不用协程实现起来很麻烦的骚操作：

  1. 如果有一个函数，它的返回值需要等到多个耗时的异步任务都执行完毕返回之后，组合所有任务的返回值作为 最终返回值
  2. 如果有一个函数，需要顺序执行多个网络请求，并且后一个请求依赖前一个请求的执行结果
  3. 当前正在执行一项异步任务，但是你突然不想要它执行了，随时可以取消
  4. 如果你想让一个任务最多执行3秒，超过3秒则自动取消

Kotlin协程之所以被认为是假协程，是因为它并不在同一个线程运行，而是真的会创建多个线程。

Kotlin协程在Android上只是一个类似线程池的封装，真就是一个线程框架。但是它却可以让我们用同步的代码风格写出异步的效果，至于怎么做的，这个不需要我们操心，这些都是kotlin帮我们处理好了，我们需要关心的是怎么用好它

它就是一个线程框架。

作者：京东物流 王斌

来源：京东云开发者社区 自猿其说Tech 转载请注明来源

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1127828.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

QSPI介绍

QSPI介绍

0 Preface/Foreword 1 QSPI介绍
阅读更多...
数据结构与算法课后题-第七章(顺序查找和折半查找)

数据结构与算法课后题-第七章(顺序查找和折半查找)

牛刀小试&#xff0c;做一下小题&#xff0c;检查一下自己的基础知识掌握的情况。 文章目录 牛刀小试1牛刀小试2牛刀小试3牛刀小试4牛刀小试5牛刀小试6牛刀小试7牛刀小试8牛刀小试9牛刀小试10牛刀小试11牛刀小试12牛刀小试13牛刀小试14牛刀小试15 牛刀小试1 牛刀小试2 错题分析…
阅读更多...
从「纯野妆」到「降温妆」，解析小红书“热词爆款学”

从「纯野妆」到「降温妆」，解析小红书“热词爆款学”

白开水妆、视觉降温妆、亚裔辣妹妆......打开小红书的美妆板块&#xff0c;你会发现许多这类极具创意的妆容热词。小红书用户乐于尝鲜、乐于创新&#xff0c;具有强大的创造能力&#xff0c;热衷于为产品、为妆容、为穿搭起“外号”。这些“外号”往往能突破原有思维的束缚&…
阅读更多...
el-select multiple表单校验问题

el-select multiple表单校验问题

el-select multiple表单校验问题 <el-form refform :modelform><el-form-item propvulTypes label漏洞类型><el-select v-modelform.vulTypes changevulTypeChange><el-option v-foritem in vulList :keyitem :labelitem :valueitem></el-option&g…
阅读更多...
智能井盖传感器特点是什么？

智能井盖传感器特点是什么？

在城市基础设施建设过程中&#xff0c;无论是国际大都市还是小县城&#xff0c;井盖所导致的问题会严重影响着城市地下生命线。井盖如若出现移动翻转等现象&#xff0c;是市民生命安全的潜在隐患&#xff0c;也有可能会影响下水道&#xff0c;供水管道等正常运行。所以传统井盖…
阅读更多...
HashMap 源码解析

HashMap 源码解析

目录 一. 前言 二. 哈希表 三. 源码解析 3.1. 数据结构 3.2. 类结构 3.3. 字段属性 3.4. 构造方法 3.5. 确定哈希桶数组索引位置 3.6. 添加元素 3.7. 扩容机制 3.8. 删除元素 3.9. 查找元素 一. 前言 HashMap基于哈希表的Map接口实现&#xff0c;是以key-value存储…
阅读更多...
JavaScript 函数 eval() ， json字符串转换

JavaScript 函数 eval() ， json字符串转换

eval() eval() 函数计算 JavaScript 字符串&#xff0c;并把它作为脚本代码来执行。 如果参数是一个表达式&#xff0c;eval() 函数将执行表达式。如果参数是Javascript语句&#xff0c;eval()将执行 Javascript 语句 console.log(eval(2 2)); // Expected output: 4console…
阅读更多...
基于SSM的论文投稿系统

基于SSM的论文投稿系统

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;Vue 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#xff1a;是 目录…
阅读更多...
PMP考试时间是什么时候？

PMP考试时间是什么时候？

PMP官方公布&#xff0c;一般来说&#xff0c;一年有4次&#xff0c;分别在3月、6月、9月和12月。具体日期或者时间变动看官方通知。 pmp干货&#xff1a;点击免费刷题&#xff0c;PMP第七版&#xff0c;预测敏捷资料免费分享&#xff01; 来说一下考试的相关情况 1、考试题型…
阅读更多...
【EI会议征稿】第十届机电一体化与工业信息学国际学术研讨会（ISMII 2024）

【EI会议征稿】第十届机电一体化与工业信息学国际学术研讨会（ISMII 2024）

第十届机电一体化与工业信息学国际学术研讨会&#xff08;ISMII 2024&#xff09; 2024 10th International Symposium on Mechatronics and Industrial Informatics 随着往年九届的成功举办&#xff0c;2024年第十届机电一体化与工业信息学国际学术研讨会&#xff08;ISMII…
阅读更多...
docker安装mqtt服务器, 并测试连接

docker安装mqtt服务器, 并测试连接

docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:5.3.0 使用mqttx进行测试: 参考: 下载 EMQX
阅读更多...
自定义命名不同类型文件，隐藏编号轻松整理，一键操作高效便捷！

自定义命名不同类型文件，隐藏编号轻松整理，一键操作高效便捷！

你是否曾经因为文件名混乱而烦恼&#xff0c;或者因为编号重复而感到困扰&#xff1f;让我们一起解决这个问题&#xff0c;推荐一款强大的文件改名工具&#xff0c;帮助你个性化文件改名&#xff0c;自定义命名不同类型文件&#xff0c;隐藏编号轻松整理&#xff01; 首先我们…
阅读更多...
软件测试进阶篇----Python

软件测试进阶篇----Python

Python python语言的学习技巧&#xff1a;多写多敲 要求能够掌握基础知识&#xff0c;能够使用python实现自动化脚本的开发即可&#xff01;&#xff01;&#xff01; 一、python语言的特点 python是一种胶水语言&#xff1a;python需求和其他的行业结合在一起才能发挥更大…
阅读更多...
Go语言Goroutine

Go语言Goroutine

在本教程中&#xff0c;我们将讨论如何使用 Goroutines 在 Go 中实现并发。 什么是 Goroutine&#xff1f; Goroutine 是与其他函数或方法同时运行的函数或方法。Goroutines 可以被认为是轻量级线程。与线程相比&#xff0c;创建 Goroutine 的成本很小。因此&#xff0c;Go 应…
阅读更多...
AI基础软件：如何自主构建大+小模型？

AI基础软件：如何自主构建大+小模型？

导读&#xff1a;AI 基础软件作为大型 AI 模型的底座&#xff0c;承载着顶层大模型的建设&#xff0c;也是大模型应用落地的关键。为了更好地支持大模型的训练和演进&#xff0c;设计与开发基础软件便显得尤为重要。本文分享了九章云极DataCanvas如何自主构建大 小模型的经验与…
阅读更多...
1024程序员节：理解编码背后的艺术

1024程序员节：理解编码背后的艺术

1024的含义 "1024"在中国互联网文化中有两个主要的含义&#xff1a; 1024是2的10次方&#xff0c;这在计算机科学中是一个重要的数字&#xff0c;因为计算机的基础是二进制。因此&#xff0c;程序员们常常把1024作为一个特殊的日子来庆祝&#xff0c;也就是10月24日…
阅读更多...
如何把项目上传到Gitee（详细教程）

如何把项目上传到Gitee（详细教程）

找到项目根目录右键打开Git Bash Here 输入命令&#xff1a;git init 回车 输入命令&#xff1a;git status 输入命令&#xff1a;git add . 输入命令&#xff1a;git status git commit -m 项目描述 在Gitee官网注册好账号后&#xff0c;git 新建项目 填写补充git项目信息及…
阅读更多...
SAP采购发票差异处理

SAP采购发票差异处理

&#xff08;一&#xff09; 税金差异 一般情况下&#xff0c;供应商的开票金额与我们的入库金额一致&#xff0c;不过有时也会出现不一致的情况&#xff0c;如通过金税系统开票出现尾差&#xff0c;或是开票价格大于订单价格。本文介绍如何处理采购发票中的税金差异。 采购订…
阅读更多...
【单调栈】84. 柱状图中最大的矩形、60天刷题总结

【单调栈】84. 柱状图中最大的矩形、60天刷题总结

提示&#xff1a;努力生活&#xff0c;开心、快乐的一天 文章目录 84. 柱状图中最大的矩形&#x1f4a1;解题思路&#x1f914;遇到的问题&#x1f4bb;代码实现&#x1f3af;题目总结 总结数组链表哈希表数组作为哈希表set作为哈希表map作为哈希表 字符串要不要使用库函数双指…
阅读更多...
Jmeter接口测试(十一)：BeanShell脚本详解

Jmeter接口测试(十一)：BeanShell脚本详解

BeanShell简介 BeanShell是一种完全符合Java语法规范的脚本语言,并且又拥有自己的一些 语法和方法&#xff1b; BeanShell是一种松散类型的脚本语言&#xff1b; BeanShell是用Java写成的&#xff0c;一个小型的、免费的、可以下载、嵌入式的 Java源代码解释器&#xff0c;具…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023