文档建议反馈控制台
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
发布

【Kotlin 协程】协程底层实现 ① ( Kotlin 协程分层架构 | 基础设施层 | 业务框架层 | 使用 Kotlin 协程基础设施层标准库 Api 实现协程 )

文章目录 一、Kotlin 协程分层架构 二、使用 Kotlin 协程基础设施层标准库 Api 实现协程 一、Kotlin 协程分层架构 ---- Kotlin 协程分层架构 : 在 Kotlin 中..., 协程分为两层 ; 基础设施层 : Kotlin 提供了 协程 标准库 Api , 为协程提供 概念 , 语义 支持 , 是 协程 实现的基础 ; Kotlin 协程的底层支持 ; 基础 Api ;...协程 的上层实现 ; 在 基础 Api 的基础上 进行了一层封装 , 形成了方便开发者使用的框架 ; 基础设施层 : 基础设施层 的 协程基础 Api 定义在 kotlin.coroutines.*...协程基础设施层标准库 Api 实现协程 ---- 协程 需要使用 协程体定义 , 协程体格式如下 : suspend { // 协程体内容 } 协程体定义完之后 , 调用协程体的 createCoroutine...: 上述 基础设施层 的 协程基础 Api 定义在 kotlin.coroutines.* 包下 ; import kotlin.coroutines.* 业务框架层 : 如果调用 常见的协程 Api

97910

【Kotlin 协程】协程底层实现 ② ( 协程调度器 | 协程任务泄漏 | 结构化并发 )

文章目录 一、协程调度器 二、协程任务泄漏 三、结构化并发 一、协程调度器 ---- 协程 是在 调度器 中运行的 , 在协程中有 3 种调度器 : Dispatchers.Main 调度器 : 在 主线程...---- 协程任务泄漏 : 发起 协程任务 后 , 无法追踪任务的执行结果 , 任务等于无效任务 , 但是仍然会消耗 内存 , CPU , 网络 , 磁盘 等资源 ; Kotlin 中引入了 结构化并发机制...避免 协程任务泄漏 的情况发生 ; 协程任务泄漏 与 内存泄漏 类似 ; 三、结构化并发 ---- 结构化并发 使用场景 : 协程任务取消 : 在不需要协程任务的时候 , 取消协程任务 ; 追踪协程任务...: 追踪正在执行的协程任务 ; 发出错误信号 : 如果 协程任务执行失败 , 发出错误信号 , 表明执行任务出错 ; 协程任务 运行时 , 必须指定其 CoroutineScope 协程作用域 , 其会追踪所有的...协程任务 , CoroutineScope 协程作用域 可以取消 所有由其启动的协程任务 ; 常见的 CoroutineScope 协程作用域 : GlobalScope : 该作用域是 进程级别的

87720
    • 您找到你想要的搜索结果了吗？
    是的
    没有找到

    Kotlin协程-特殊的阻塞协程

    阻塞协程是种特殊的协程启动方式，一般是用 runBlocking{} 扩起来一段协程。...这里给出结果，改用GlobalScope.launch之后，子协程会在一个独立的线程里运行。 runBlocking 在kotlin协程官网上对于这个api的解释是桥接阻塞与非阻塞的世界。...EventLoop是协程里对阻塞型coroutine进行调度的默认调度器。runBlocking和launch的主要区别就靠EventLoop实现。...在创建完coroutine后就进入派发流程了，这部分和Kotlin协程-一个协程的生命周期中的逻辑比较相似，下面也会讲到。...这个问说明，runBLocking{}这种协程，它的运行逻辑是先把父协程放队列里，然后取出来执行，执行完毕再把子协程入队，再出队子协程，用同样的方式递归。

    2.7K20

    Kotlin协程开篇

    《Kotlin协程》均基于Kotlinx-coroutines 1.3.70 新开个坑，专门讲kotlin的协程。聊协程之前先说一下具体聊的是协程的什么内容。 · 协程是什么？ · 什么时候用协程？...· 协程的核心是什么？ · kotlin的协程和其他语言的协程有什么异同？ kotlin的协程的出现其实比kotlin语言还晚一点。在当前这个版本，协程甚至都还处于一个不稳定的迭代版本中。...这个问题涉及到Kotlin协程的Scope，调度，也是协程的实现核心逻辑 Kotlin不是第一个提出协程的 实际上在Kotlin之前就有不少语言实践了协程这个概念。比如python，golang。...golang做了什么 golang的协程叫goroutine，跟kotlin的coroutine差不多。golang用一种程序员更容易理解的抽象定义了协程粒度goroutine，还有它的各种操作。...kotlin的协程还在发展 如果去看kotlin的协程源码的话会发现里面有很多 exeprimental 的api和实现逻辑。

    1.1K20

    Kotlin 协程总结

    文章目录 一、协程是什么 1.简介 2.协程好在哪 3.协程具体怎么用 a.添加依赖 b.开始使用 c.suspend 4.小结 二、挂起是什么 1....1.简介 协程并不是 Kotlin 提出来的新概念，其他的一些编程语言，例如：Go、Python 等都可以在语言层面上实现协程，甚至是 Java，也可以通过使用扩展库来间接地支持协程。...协程设计的初衷是为了解决并发问题，让 「协作式多任务」 实现起来更加方便。 协程就是 Kotlin 提供的一套线程封装的 API，但并不是说协程就是为线程而生的。...现在先把这个概念放下，只需要记住协程就是这样写的就行了。 这种「用同步的方式写异步的代码」看起来很方便吧，那么我们来看看协程具体好在哪。...3.协程与线程 在 Kotlin 里，协程就是基于线程来实现的一种更上层的工具 API，类似于 Java 自带的 Executor 系列 API 或者 Android 的 Handler 系列 API。

    3.7K11

    【Kotlin 协程】协程启动 ② ( 多协程控制 | launch 协程执行顺序控制 | Job#join() 函数 | async 协程执行顺序控制 | Deferred#await() 函数 )

    87183425 一、launch 协程执行顺序控制 ---- 如果需要通过 launch 协程构建器 启动多个协程 , 后面的协程需要等待前面的协程执行完毕 , 在启动靠后的协程 , 实现方案如下 :...---- 如果需要通过 async 协程构建器 启动多个协程 , 后面的协程需要等待前面的协程执行完毕 , 在启动靠后的协程 , 实现方案如下 : 调用 Deferred#await() 函数 , 可以挂起协程..., 等待 async 中协程体内的任务执行完毕 , 再执行后面的协程任务 ; 代码示例 : 下面的代码中 , 先执行 asyncDeferred 协程 , 调用 asyncDeferred.await...Log.i(TAG, "asyncDeferred 执行完毕") } // 挂起协程 , 等待协程执行完毕会后再执行后面的协程任务 asyncDeferred.await()..., 等待协程执行完毕会后再执行后面的协程任务 asyncDeferred1.await() val asyncDeferred2 = async {

    1.2K20

    破解 Kotlin 协程(5) - 协程取消篇

    关键词：Kotlin 协程 协程取消 任务停止 协程的任务的取消需要靠协程内部调用的协作支持，这就类似于我们线程中断以及对中断状态的响应一样。 1. 线程的中断 我们先从大家熟悉的话题讲起。...再谈 Retrofit 的协程扩展 4.1 Jake Wharton 的 Adapter 存在的问题 我在破解 Kotlin 协程 - 入门篇(https://www.bennyhuo.com/2019...() 的时候抛了个取消异常，这主要是因为 await() 所在的协程已经被我们用 cancelAndJoin() 取消，但从随后 invokeOnCompletion 的回调结果来看， getUserCoroutine...，它的构造可接受一个 Job 实例作为它的父协程，那么问题来了，这里并没有告诉它父协程究竟是谁，因此也就谈不上作用域的事儿了，这好像我们用 GlobalScope.launch 启动了一个协程一样。...，只不过如果你对这些都不熟悉，那么可能需要多加练习培养出感觉，而不必一开始就关注原理和细节，依样画葫芦一样可以用的很好，就像大家不知道 RxJava 原理一样可以用的很好一样，协程也可以做到这一点的。

    2.1K50

    破解 Kotlin 协程(2) - 协程启动篇

    说实话，这个线程的 start 的设计其实是很奇怪的，不过我理解设计者们，毕竟当年还有 stop 可以用，结果他们很快发现设计 stop 就是一个错误，因为不安全而在 JDK 1.1 就废弃，称得上是最短命的...这段程序采用默认的启动模式，由于我们也没有指定调度器，因此调度器也是默认的，在 JVM 上，默认调度器的实现与其他语言的实现类似，它在后台专门会有一些线程处理异步任务，所以上述程序的运行结果可能是： 19...JVM 上默认调度器的实现也许你已经猜到，没错，就是开了一个线程池，但区区几个线程足以调度成千上万个协程，而且每一个协程都有自己的调用栈，这与纯粹的开线程池去执行异步任务有本质的区别。...在 Nodejs 中，Kotlin 协程的默认调度器则并没有实现线程的切换，输出结果也会略有不同，这样似乎更符合 JavaScript 的执行逻辑。 更多调度器的话题，我们后续还会进一步讨论。...所以这个所谓的”需要“，其实是一个很有趣的措辞，后面你还会看到我们也可以通过 await 来表达对 Deferred 的需要。

    1.2K30

    破解 Kotlin 协程(3) - 协程调度篇

    关键词：Kotlin 异步编程 协程 上一篇我们知道了协程启动的几种模式，也通过示例认识了 launch 启动协程的使用方法，本文将延续这些内容从调度的角度来进一步为大家揭示协程的奥义。 ? 1....协程上下文 调度器本质上就是一个协程上下文的实现，我们先来介绍下上下文。...用过 OkHttp 的小伙伴一下就兴奋了，拦截器我常用的啊，OkHttp 用拦截器做缓存，打日志，还可以模拟请求，协程拦截器也是一样的道理。...， dispatch 方法会在拦截器的方法 interceptContinuation 中调用，进而实现协程的调度。...anko-coroutines 当中的 View.onClick 扩展，这样我们就无需自己在这里用 launch 启动协程了。

    87820

    破解 Kotlin 协程(6) - 协程挂起篇

    关键词：Kotlin 协程 协程挂起 任务挂起 suspend 非阻塞 协程的挂起最初是一个很神秘的东西，因为我们总是用线程的概念去思考，所以我们只能想到阻塞。不阻塞的挂起到底是怎么回事呢？...先看看 delay 我们刚刚学线程的时候，最常见的模拟各种延时用的就是 Thread.sleep 了，而在协程里面，对应的就是 delay。...，为了做到这一点，我们用 Java 来仿写一下这段逻辑： 注意，下面的代码逻辑上并不能做到十分严谨，不应该出现在生产当中，仅供学习理解协程使用。...就是 Kotlin 协程编译之后产生的字节码。...当然，这一篇内容的安排更多是为后面的序列篇开路，Kotlin 的 Sequence 就是基于协程实现的，它的用法很简单，几乎与普通的 Iterable 没什么区别，因此序列篇我们会重点关注它的内部实现原理

    1.3K30

    Kotlin协程实现原理:挂起与恢复

    今天我们来聊聊Kotlin的协程Coroutine。 如果你还没有接触过协程，推荐你先阅读这篇入门级文章What? 你还不知道Kotlin Coroutine?...Kotlin协程实现原理:Suspend&CoroutineContext Kotlin协程实现原理:CoroutineScope&Job Kotlin协程实现原理:ContinuationInterceptor...协程的所谓非阻塞式挂起与恢复又是什么？ 协程的内部实现原理是怎么样的？ ... 接下来的一些文章试着来分析一下这些疑问，也欢迎大家一起加入来讨论。 挂起 协程是使用非阻塞式挂起的方式来保证协程运行的。...，内部执行一个async方法，通过await方法触发协程的挂起。...进入case: 0后输出async start，调用async并通过await来挂起当前协程，再挂起的过程中记录当前挂起点的数据，并将lable设置为1。

    2.4K10

    【翻译】深入 Kotlin 协程

    【翻译】深入 Kotlin 协程 2017-10-26 by Liuqingwen | Tags: Kotlin 翻译 | Hits ? 一、前言 翻译好的文章也是一种学习方法！...解决方案 3 ： Coroutines 协程 这是我们使用协程来实现的代码的模样： button.setOnClickListener { launch(UI){ val userString...如何使用协程？ 协程基于一种新的函数类型，叫做挂起函数。我们可以在函数名称前使用一种新的语言关键字 suspend 来标记。用这个关键字标记的函数能够暂停一个协程的执行，且不会阻塞当前线程。...在 C# 中 async 和 await 都是关键字 在 C# 中 async 函数只能返回一个 Task 实例或者返回空 如果你仔细观察协程的这个例子，你会看到在 Kotlin 中， launch{}...神奇的状态机 协程的内部实现机制涉及到一些关于编译器危险魔法的黑色艺术。

    1.6K10

    破解 Kotlin 协程 番外篇(2) - 协程的几类常见的实现

    关键词：协程 分类 所谓知己知彼，百战不殆。为了搞清楚 Kotlin 协程是怎么回事，我们也来看看其他语言的协程是怎么实现的。...Kotlin 的协程是一种无栈协程的实现，它的控制流转依靠对协程体本身编译生成的状态机的状态流转来实现，变量保存也是通过闭包语法来实现的，不过 Kotlin 的协程可以在任意调用层次挂起，换句话说我们启动一个...从实现的角度来讲，非对称协程的实现更自然，也相对容易；不过，我们只要对非对称协程稍作修改，即可实现对称协程的能力。...相比之下，有朋友抱怨 Kotlin 的协程没有其他语言的 async/await 那么容易上手，也没有 go routine 那么容易使用，原因也很简单，Kotlin 的协程用一个最基本的 suspend...关键字来支持了最基本的挂起恢复逻辑，进而在上层封装，衍生出了以上提到的几乎所有的模型，让我们在 Kotlin 当中可以有机会使用 async/await、Channel，以及最新出的 Flow API

    1.6K31

    Kotlin协程实现原理:Suspend&CoroutineContext

    今天我们来聊聊Kotlin的协程Coroutine。 如果你还没有接触过协程，推荐你先阅读这篇入门级文章What? 你还不知道Kotlin Coroutine?...如果你已经接触过协程，相信你都有过以下几个疑问： 协程到底是个什么东西？ 协程的suspend有什么作用，工作原理是怎样的？...协程的所谓非阻塞式挂起与恢复又是什么？ 协程的内部实现原理是怎么样的？ ... 接下来的一些文章试着来分析一下这些疑问，也欢迎大家一起加入来讨论。...当然，如果你有关注我之前的文章，应该就会有所了解，因为在重温Retrofit源码，笑看协程实现这篇文章中我已经有简单的提及。...在Kotlin中比较特殊，它可以代表任意类型。

    1.9K10

    Kotlin协程系列(二)

    在进行业务开发时，我们通常会基于官方的协程框架(kotlinx.coroutines)来运用Kotlin协程优化异步逻辑，不过这个框架过于庞大和复杂，如果直接接触它容易被劝退。...() } 　　　　这里多了一个泛型参数T，T表示返回值类型，通过它的await函数可以拿到这个返回值，因此await函数的主要作用有：在协程执行完成时，立即拿到协程的结果；如果协程尚未完成，则挂起协程，...，首先定义一个挂起函数，然后用delay(1000)函数来模拟耗时操作，然后我们用async启动协程，并获取协程的返回值，代码如下： suspend fun getValue():String{...，不过还有一个问题没有解决，我们的协程是如何实现并发的？...协程需要调度的位置就是挂起点的位置，当协程执行到挂起点的位置时，如果产生了异步行为，协程就会在这个挂起点挂起，只有协程在挂起点正真挂起时，我们才有机会实现调度，而实现调度器需要使用协程的拦截器。

    38210

    Kotlin协程实现原理:ContinuationInterceptor&CoroutineDispatcher

    今天我们继续来聊聊Kotlin的协程Coroutine。 如果你还没有接触过协程，推荐你先阅读这篇入门级文章What? 你还不知道Kotlin Coroutine?...Kotlin协程实现原理:Suspend&CoroutineContext Kotlin协程实现原理:CoroutineScope&Job 如果你已经接触过协程，相信你都有过以下几个疑问： 协程到底是个什么东西...协程的所谓非阻塞式挂起与恢复又是什么？ 协程的内部实现原理是怎么样的？ ... 接下来的一些文章试着来分析一下这些疑问，也欢迎大家一起加入来讨论。...自然在协程中ContinuationInterceptor的作用也是用来做拦截协程的。 下面来看下它的实现。...大家是否还记得在Kotlin协程实现原理系列的第一篇文章中，我们分析了CoroutineContext的内部结构，当时提到了它的plus方法，就是下面这段代码 public operator fun plus

    1.9K10
    点击加载更多

    相关资讯

    热门标签

    更多标签

    活动推荐

      运营活动

      活动名称
      广告关闭

      腾讯云开发者

      扫码关注腾讯云开发者

      扫码关注腾讯云开发者

      领取腾讯云代金券

      热门产品

      热门推荐

      更多推荐

      Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有

      深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

      腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287

      领券