一、select 函数原型 ---- 在上一篇博客 【Kotlin 协程】协程中的多路复用技术 ① ( 多路复用技术 | await 协程多路复用 | Channel 通道多路复用 ) 中 , 介绍了...协程多路复用技术 , 多路复用 主要使用 select 代码块 实现 , 在 select 代码块中 调用多个协程的 onAwait 函数 , 哪个协程先返回数据 , 就选择该协程的数据作为返回值 ;...调用者被挂起，直到其中一个子句 * 是_selected_或_fails_。 * * 最多一个子句被*原子地*选中，并且它的块被执行。所选子句的结果 * 成为选择的结果。...如果有任何子句_fails_，则选择调用将生成 * 相应的异常。在本例中没有选择子句。 * * 这个选择函数是_biased_到第一个子句。当可以同时选择多个子句时， * 第一个有优先权。...相反，每个可选择的挂起函数都具有 * 对应的非挂起版本，可以与常规的“when”表达式一起使用来选择一个 * 的选项，如果没有选项可以立即选择，则执行默认(' else ')操作。
· 协程的核心是什么？ · kotlin的协程和其他语言的协程有什么异同？ kotlin的协程的出现其实比kotlin语言还晚一点。在当前这个版本，协程甚至都还处于一个不稳定的迭代版本中。...delay(1000L) // 非阻塞的等待 1 秒钟（默认时间单位是毫秒） println("World!")...存活 } 上面的代码是一个常规启动协程的方式，关键函数只有 launch，delay，这两个函数是kotlin协程独有的。...().name}") delay(1000L) // 非阻塞的等待 1 秒钟（默认时间单位是毫秒） println("World!")...println("Thread: ${Thread.currentThread().name}") delay(1000L) // 非阻塞的等待 1 秒钟（默认时间单位是毫秒
launch函数它以非阻塞（non-blocking）当前线程的方式，启动一个新的协程后台任务，并返回一个Job类型的对象作为当前协程的引用。...另外，这里的delay()函数类似Thread.sleep()的功能，但更好的是：它不会阻塞线程，而只是挂起协程本身。...Thread.sleep(5000L) } 9.2 桥接 阻塞和非阻塞 上面的例子中，我们给出的是使用非阻塞的delay函数，同时有使用了阻塞的Thread.sleep函数，这样代码写在一起可读性不是那么地好...让我们来使用纯的Kotlin的协程代码来实现上面的 阻塞+非阻塞 的例子（不用Thread）。...该runBlocking函数不是用来当做普通协程函数使用的，它的设计主要是用来桥接普通阻塞代码和挂起风格的（suspending style）的非阻塞代码的, 例如用在 main 函数中，或者用于测试用例代码中
异步编程 体验 语言级 理念 注意上面几个关键点和一些实际使用，不难明白 Kotlin协程是基于Kotlin语法从而延伸的一个异步编程框架，它并没有带来多少性能上的体验，它能实现的，你用线程池同样也可以实现...，但对于使用角度的来说，协程努力打造一个 "同步方式，异步编程的" 思想，作为开发者来说，我们可以更懒了，切换线程，withContext即可，协程带来了开发上的舒适，但这种舒适是基于 Kotlin 的语法...那上面注释中 挂起 是什么意思呢？ 什么是挂起？ 观察上面的打印日志，我们不难发现，在调用 delay 函数时，线程并没有停下，相对来说，只是我们的协程代码块被挂起，等待恢复。...只有前面的挂起函数执行结束，我们的协程代码块才能继续执行。借用一幅图来说明如下： 所以所谓的挂起其实是代码层次的一个处理，从而使得我们可以以同步形式去写异步的代码。 非阻塞程序？...所谓的非阻塞，其实就是切换了线程，观察打印日志变化，我们可以发现，当我们直接 GlobalScope.launch 启动一个协程时，此时运行的线程为默认的线程，所以协程被称为非阻塞的实现方式。
注意： 1.单协程内多 suspend 函数运行：suspend 函数挂起，挂起的是当前suspend 函数所在的协程；一个协程内的多个suspend 挂起函数是顺序执行的，上面的suspend函数没执行完是不会执行其他的...一个withContext和一个delay都是可以实现挂起，withContext挂起时间取决于包裹的代码块运行时间，delay是直接设置挂起时间，delay挂起阻塞当前运行delay的协程，delay...4.runBlocking {}会等待所有子协程执行完毕 2、非阻塞式挂起：就是用阻塞式的代码写法，实现了非阻塞式的功能（同步代码写法实现异步任务） runBlocking本身会阻塞当前线程去等待...不同之处在于 launch 返回一个 Job 并且不附带任何结果值，而 async 返回一个 Deferred 包裹的值—— >一个轻量级的非阻塞协程。...从源码可知folw内是执行了挂起函数的，flow是协程中的库，只能用于协程环境。
但是我认为这种比喻不对，更好的解释是kotlin 的协程其实是 kotlin 线程池中的一个任务（Task）；我们能执行协程操作，其实是因为调用了协程框架的接口，该协程框架是对线程池的进一步封装。...大概的原理如下图所示： 可以看到，Java线程池的实现是通过阻塞队列存储任务，然后线程不断地执行任务；而 kotlin 的线程池，则是线程中存储任务，kotlin线程池负责调度任务。...runBlocking 则是一个顶层方法，它可以获取协程的执行结果，但这种方式会阻塞代码的执行流程，因此只建议在测试中使用。上面的代码示例是使用 launch 来创建协程。...CoroutineContext 是指协程的上下文。不同于 Android 中 Context，CoroutineContext 的功能更像一个 Map，它内部包含多种类型的元素。...至于为什么协程提供的挂起函数，像delay，可以自动响应协程的取消呢？
安静的妹子.jpg 一. 协程 Kotlin 在1.1版本之后引入了协程的概念，目前它还是一个试验的API。 在操作系统中，我们知道进程和线程的概念以及区别。...Kotlin 的协程是无阻塞的异步编程方式。Kotlin 允许我们使用协程来代替复杂的线程阻塞操作，并且复用原本的线程资源。 Kotlin 的协程是依靠编译器实现的, 并不需要操作系统和硬件的支持。...协程常用的基本概念 2.1 CoroutineContext 协程上下文，它包含了一个默认的协程调度器。所有协程都必须在 CoroutineContext 中执行。...我们使用 suspend 关键字来修饰可以被挂起的函数。被标记为 suspend 的函数只能运行在协程或者其他 suspend 函数中。...} delay(2000) } runBlocking 创建的协程直接运行在当前线程上，同时阻塞当前线程直到结束。
所以，suspend 关键字更多的是给调用者一个提示，提示调用者被它修饰的方法是个耗时方法，需要在协程或者其他 suspend 函数中处理，限制这个方法只能在协程或其他 suspend 函数中被调用。...3.4 协程作用域 launch 函数的第三个参数是一个由外层 CoroutineScope 调用的 lambda 闭包，我们需要在协程中处理的逻辑都在这个闭包中实现。...而 launch 则是非阻塞的，先来看一下非阻塞的情况： // code 6 非阻塞协程 GlobalScope.launch { delay(5000) Log.d(TAG, " 1...函数也是一个挂起函数，它可以非阻塞性的挂起当前线程，并且在设置的时间间隔之后恢复执行，是可被取消的。...async 返回的是一个 Deferred 接口对象，继承自 Job，且包含一个返回结果。Deferred 是一个非阻塞的，可被取消的对象。
方便性能优化这一点主要得益于Kotlin的协程，可以看看之前介绍协程的文章：Android面试题之Kotlin协程一文搞定 和 Kotlin协程上下文和异常处理协程帮我们很好的解决了一个问题，就是App...Kotlin 协程是一种协程 (Coroutine) 编程模型，是 Kotlin 标准库的一部分。...协程可以看作是轻量级的线程，它们可以在线程中运行，但与传统线程不同，协程是非阻塞、低开销的，可以极大程度地提高并发任务的执行效率。Kotlin 协程解决的传统 Java 线程管理问题1....Kotlin 协程：协程是轻量级的，可以在同一个线程中创建成千上万个协程，极大地减少了内存消耗。协程的内存占用远小于传统线程。3....Kotlin 协程：协程支持挂起函数（suspend functions），在等待期间释放线程资源，不会阻塞线程。使用 suspend 关键字进行非阻塞操作，使得程序的资源利用率更高。
Coroutine是kotlin官方文档上推荐的，个人理解，其实就是一个轻量级的线程库。.../ 非阻塞的等待 1 秒钟（默认时间单位是毫秒） println("World!")...其实GlobalScope.launch可以通过Thread来替代，但要注意delay是一个特殊的 挂起函数 ，它不会造成线程阻塞，但是会 挂起 协程，并且只能在协程中使用。...在协程内部可以像普通函数一样使用挂起函数， 不过其额外特性是，同样可以使用其他挂起函数（如本例中的 delay）来挂起协程的执行。...因为一段协程代码必须协作才能被取消 协程的取消是 协作 的。一段协程代码必须协作才能被取消。 所有 kotlinx.coroutines 中的 挂起函数 都是 可被取消的 。
关键词：Kotlin 协程 协程挂起 任务挂起 suspend 非阻塞 协程的挂起最初是一个很神秘的东西，因为我们总是用线程的概念去思考，所以我们只能想到阻塞。不阻塞的挂起到底是怎么回事呢？...sleep 让线程进入休眠状态，直到指定时间之后某种信号或者条件到达，线程就尝试恢复执行，而 delay 会让协程挂起，这个过程并不会阻塞 CPU，甚至可以说从硬件使用效率上来讲是“什么都不耽误”，从这个意义上讲...delay 也可以是让协程休眠的一种很好的手段。...当然，字节码是比较抽象的，我这样写出来就是为了让大家更容易的理解协程是如何执行的，看到这里，相信大家对于协程的本质有了进一步的认识： 协程的挂起函数本质上就是一个回调，回调类型就是 Continuation...协程体的执行就是一个状态机，每一次遇到挂起函数，都是一次状态转移，就像我们前面例子中的 label 不断的自增来实现状态流转一样 如果能够把这两点认识清楚，那么相信你在学习协程其他概念的时候就都将不再是问题了
前言 Kotlin协程底层是用线程实现的，是一个封装完善供开发者使用的线程框架。...Kotlin的一个协程可以理解为是运行在线程上的一个执行任务并且该任务可以在不同的线程间切换，一个线程可以同时运行多个协程。...从开发者角度来看：kotlin协程可以实现以同步的方式去编写异步执行的代码，解决线程切换回调的嵌套地狱。 协程挂起时不需要阻塞线程，几乎是无代价的。...创建协程的方式 runBlocking 这是一个顶层函数，会启动一个新的协程并阻塞调用它的线程，直到里面的代码执行完毕,返回值是泛型T。...launch启动一个协程，不会阻塞调用它的线程，返回值是Job。
通道是使用 SendChannel 和使用 ReceiveChannel 之间的非阻塞通信。 9.10.1 通道 vs 阻塞队列 通道的概念类似于 阻塞队列（BlockingQueue）。...send函数被挂起直到另外一个协程调用receive函数， 然后receive函数挂起直到另外一个协程调用send函数。它是一个完全无锁的实现。...通常多个运行在同一调度器中的协程运行在一个线程内，这也消除掉了多线程同步等带来的编程复杂性。同一时刻同一调度器中的协程只有一个会处于运行状态。...而线程阻塞的代价通常是昂贵的，尤其在高负载时，阻塞其中一个会导致一些重要的任务被延迟。 另外，协程挂起几乎是无代价的。不需要上下文切换或者 OS 的任何其他干预。...我们看到协程通过挂起机制实现非阻塞的特性大大提升了我们并发性能。 最后，我们还简单介绍了协程的实现的原理以及标准API库。Kotlin的协程的实现大量地调用了Java中的多线程API。
协程的所谓非阻塞式挂起与恢复又是什么？ 协程的内部实现原理是怎么样的？ ... 接下来的一些文章试着来分析一下这些疑问，也欢迎大家一起加入来讨论。 挂起 协程是使用非阻塞式挂起的方式来保证协程运行的。...那么什么是非阻塞式挂起呢？下面我们来聊聊挂起到底是一个怎样的操作。...而它另一个关键作用是起到挂起协程的标识。 协程运行的时候每遇到被suspend修饰的方法时，都有可能会挂起当前的协程。 注意是有可能。...由于post 1s所以比协程中dealy还短，所以会优先输出main end，然后再过1s，进入恢复协程阶段 async中的协程被delay恢复，注意在delay方法中传入了this，async的Continuation...在需要挂起的时候，先保留现场与设置下一个状态点，然后再通过退出方法的方式来挂起协程。在挂起的过程中并不会阻塞当前的线程。
在这一次分享中，发现 Flow 和 Channel 这一块儿知识是自己不怎么了解的，本文也将着重和大家聊一聊这一块儿的内容，协程部分将分为三篇，本文是第一篇： “《即学即用Kotlin - 协程》 《抽丝剥茧...协程可以使用阻塞的方式写出非阻塞式的代码，解决并发中常见的回调地狱，这是其最大的优点，后面介绍。 2....协程作用域 协程的作用域有三种，他们分别是： runBlocking：顶层函数，它和 coroutineScope 不一样，它会阻塞当前线程来等待，所以这个方法在业务中并不适用 。...协程的原理跟九心点外卖的原理是一致的，耗时阻塞的操作并没有减少，只是交给了其他线程： ?...协程中出了一种叫 Mutex 的锁，区别是它的 lock 操作是挂起的，非阻塞的，感兴趣的同学可以自行查看。
搞清楚内部概念对分析协程源码来说非常关键。 协程的最小粒度-Coroutine 对没接触过协程的人来说，一个OOP代码的最小调度粒度是函数。...在协程中，最小的调度粒度是协程，在kotlin中叫coroutine。...println("launch 3 > Thread: ${Thread.currentThread().name}") delay(1000L) // 非阻塞的等待 1 秒钟（...按理说接下来应该是“Hello”，但实际情况是“launch 3”。 因为协程在遇到挂起函数delay的时候，会把当前coroutine挂起，然后调度另外一个待执行的coroutine去执行。...对应开发者来说，一个协程的最小粒度coroutine，在协程的内部概念中叫DispatchedContinuation。
第一个协程 在使用协程之前，需要保证Kotlin-Gradle-Plugin的版本高于1.3。目前最高的版本为1.3.11。...否则编译会报错 首先来创建一个协程： GlobalScope.launch { // 在后台启动一个新的协程并继续 delay(1000L) // 非阻塞的等待 1 秒钟（默认时间单位是毫秒...如果我们忘记保持对新启动的协程的引用，它还会继续运行。 阻塞的协程runBlocking GlobalScope.launch启动了一个线程创建新的协程，并没有阻塞当前线程。...delay()会阻塞当前线程 在runBlocking中调用launch()会开启新的协程，并且不会阻塞当前线程 在runBlocking中调用launch()会在当前线程中执行协程 main @coroutine...，才会继续执行 挂起函数 当协程中的代码超级多的时候，通常都会把这些代码提取到一个函数中。
a.什么时候需要自定义 suspend 函数 a.具体该怎么写 5.小结 三、挂起的非阻塞式是怎么回事 1.什么是「非阻塞式挂起」 2.为什么要讲非阻塞式挂起 3.协程与线程 4.小结 四、总结 一、协程是什么...不过，我们学习 Kotlin 中的协程，一开始确实可以从线程控制的角度来切入。因为在 Kotlin 中，协程的一个典型的使用场景就是线程控制。...」，讲的是「非阻塞式」这个是挂起的一个特点，也就是说，协程的挂起，就是非阻塞式的，协程是不讲「阻塞式的挂起」的概念的。...四、总结 协程就是切线程； 挂起就是可以自动切回来的切线程； 挂起的非阻塞式指的是它能用看起来阻塞的代码写出非阻塞的操作，就这么简单。 参考： 1，Kotlin 的协程用力瞥一眼 - 学不会协程？...很可能因为你看过的教程都是错的 2，Kotlin 协程的挂起好神奇好难懂？今天我把它的皮给扒了 3，到底什么是「非阻塞式」挂起？协程真的更轻量级吗？
kotlin的协程有4中启动模式 1.DEFAULT：协程创建后，立即开始调度，在调度前如果被取消，直接进入取消响应状态 2.ATOMIC：协程创建后，立即开始调度，协程执行到第一个挂起点之前不响应取消...1.runBlocking与coroutineScope runBlocking是常规函数，它会阻塞主线程，而coroutineScope是挂起函数，它们都会等待其协程体和子协助执行结束，作用域构建器使用的是父协程的上下文...二、协程取消 1.协程的取消 1.取消作用域会取消它的子协程，CoroutineScope是创建一个全新的协程上下文，和coroutineScope作用域是不同的，作用域构建器使用的是父协程的上下文 fun...2.CPU密集型任务取消 1.isActive是一个可以被使用在CorountineScope中的扩展属性，检查Job是否处于活跃状态 fun `test cancel cpu`() = runBlocking...，如果想要协程取消后，还能调用挂起函数，我们需要将清理的代码放入NoCancellable CoroutineContext中 这样会挂起运行中的代码，并保持协程的取消中状态，直到任务处理完成 fun
Kotlin 协程作用 让线程主动释放CPU是协程一个作用，一个协程执行后挂起，然后让另一个协程执行， 等到这个协程执行完毕再让前一个协程继续执行。...协程可以不依赖于线程直接运行在进程中； 协程通过提升CPU的利用率，进而减少线程切换，进而提升程序运行效率； 协程启动与停止都是由代码操作，而不是操作系统调度； Kotlin 协程练习 Kotlin 练习参考... //delay 是挂起函数，不会造成线程阻塞，只能在协程中使用 delay(1000L)//无阻塞1秒然后输出 Log.i(tag...，这个协程是轻量级的，与其他协程一起并发工作，与launch启动协程不同，launch启动返回一个Job对象 // 不带有任何返回值，而async返回一个Defrred对象一个轻量级非阻塞future...挂起后，它将完全由所运行的线程中恢复挂起函数， //非受限调度器是合适的，它在协程没有消耗CPU时间或共享数据时被限制在指定线程中 fun testDispatcherMain() =
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
