Kotlin: 协程的四种启动模式(CoroutineStart)

这篇具有很好参考价值的文章主要介绍了Kotlin: 协程的四种启动模式(CoroutineStart)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

点击查看CoroutineStart英文文档

创建协程的三种方式

  1. runBlocking
    运行一个协程并且会阻塞当前线程,直到它完成。
  2. launch
    启动一个新的协程,不会阻塞当前线程,并且返回一个Job,可以取消。
  3. async
    async和await是两个函数,这两个函数在我们使用过程中一般都是成对出现的。
    async用于启动一个异步的协程任务,await用于去得到协程任务结束时返回的结果,结果是通过一个Deferred对象返回的。

    在概念上,async 就类似于 launch。它启动了一个单独的协程,这是一个轻量级的线程并与其它所有的协程一起并发的工作。不同之处在于 launch 返回一个 Job 并且不附带任何结果值,而 async 返回一个 Deferred —— 一个轻量级的非阻塞 future, 这代表了一个将会在稍后提供结果的 promise。可以使用 .await() 在一个延期的值上得到它的最终结果, 但是 Deferred 也是一个 Job,所以如果需要的话,你可以取消它。

CoroutineStart源码

kotlin 几种协成,# kotlin,kotlin,android

协程的四种启动模式一:DEFAULT

Default——根据上下文立即调度协程执行。
如果协程上下文的[CoroutineDispatcher]从[CoroutineDispatcher. isdispatchneeded]返回’ true ’
函数,然后协程代码被调度以供稍后执行,而代码被调度
被调用的协程构建器继续执行。

注意[Dispatchers。unconstrained总是从它的[CoroutineDispatcher.isDispatchNeeded]返回false
函数,所以用[Dispatchers. *]启动协程。unconstrained [DEFAULT]与使用[un分派]相同。

如果协程[Job]在它有机会开始执行之前被取消,那么它将不会启动它的执行,但将以异常完成。

在挂起点的协同程序的可取消性取决于的具体实现细节暂停功能。使用[suspenpendcancellablecoroutine]实现可取消的挂起函数。

示例

fun main() = runBlocking {
    val job = launch (start = CoroutineStart.DEFAULT){
        println("开始执行耗时操作...")
        delay(2000L)
        println("耗时操作结束")
    }
    delay(1000L)
    job.cancel()
    println("任务取消了")
}

运行结果
kotlin 几种协成,# kotlin,kotlin,android

协程的四种启动模式二:LAZY

仅在需要时才惰性地启动协程。

详细信息请参见相应协程构建器的文档
(如[launch][CoroutineScope])。launch]和[async][coroutincope .async])。

如果协程[Job]在它有机会开始执行之前被取消,那么它将不会启动它的执行,但将以异常完成。


fun main() = runBlocking {
    val job = async  (start = CoroutineStart.LAZY){
        println("开始执行耗时操作...")
        delay(2000L)
        println("耗时操作结束")
    }
    delay(1000L)
    job.cancel()
    println("任务取消了")
    job.await()
}

运行结果
kotlin 几种协成,# kotlin,kotlin,android

协程的四种启动模式三:ATOMIC

自动地(即,以一种不可取消的方式)根据上下文调度协程的执行。
这类似于[DEFAULT],但是协程在开始执行之前不能被取消。

在挂起点的协程是否可取消,取决于挂起函数如[DEFAULT]。

@ExperimentalCoroutinesApi //从1.0.0开始,没有稳定性的ETA


fun main() = runBlocking {
    val job = async(start = CoroutineStart.ATOMIC) {
        println("开始执行耗时操作...")
        //在挂起点之前不会被取消
        delay(2000L)//这里就是一个挂起点, delay是挂起函数
        println("耗时操作结束")
    }
    delay(1000L)
    job.cancel()
    println("任务取消了")
}

运行结果
kotlin 几种协成,# kotlin,kotlin,android

协程的四种启动模式四:UNDISPATCHED

立即执行协程,直到它在当前线程中的第一个挂起点
协程是使用[dispatchers . unconstrained]启动的。但是,当协程从暂停状态恢复时
根据上下文中的[CoroutineDispatcher]进行分派。

这类似于[ATOMIC],因为协程即使已经被取消也会开始执行。
但不同之处在于它在同一个线程中开始执行。

在挂起点的协程是否可取消,取决于挂起函数如[DEFAULT]。

注:这是一个实验性api。当使用此模式时,协程的执行语义可能会在将来发生变化。
@ExperimentalCoroutinesApi //从1.0.0开始,没有稳定性的ETA

fun main() = runBlocking {
    val job = async(context = Dispatchers.IO, start = CoroutineStart.UNDISPATCHED) {
        println("开始执行耗时操作... ${Thread.currentThread().name}")
        //在挂起点之前不会被取消
        delay(2000L)//这里就是一个挂起点, delay是挂起函数
        println("耗时操作结束...${Thread.currentThread().name}")
    }
    delay(1000L)
    job.cancel()
    println("任务取消了...${Thread.currentThread().name}")
}

运行结果
kotlin 几种协成,# kotlin,kotlin,android

从上图可以看到, async(context = Dispatchers.IO, start = CoroutineStart.UNDISPATCHED) ,但是还在主线程执行的。

推荐

Kotlin:组合挂起函数文章来源地址https://www.toymoban.com/news/detail-856249.html

到了这里,关于Kotlin: 协程的四种启动模式(CoroutineStart)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Kotlin 如何确定协程是否启动

    在Kotlin中,你可以确定协程是否已启动并正在运行,可以使用 Job接口 来管理协程,并使用一些函数来检查协程的状态。以下是一些常见的方法: 1.launch 函数返回一个 Job 对象,可以使用这个对象来确定协程的状态。例如: 在上面的示例中,isActive 函数用于检查协程是否处于

    2024年02月08日
    浏览(35)
  • docker中的四种网络模式

    Docker使用Linux桥接,在宿主机虚拟一个Docker容器网桥(docker0),Docker启动一个容器时会根据Docker网桥的网段分配给容器一个IP地址,称为Container-IP,同时Docker网桥是每个容器的默认网关。因为在同一宿主机内的容器都接入同一个网桥,这样容器之间就能够通过容器的Container-IP直接

    2024年02月04日
    浏览(54)
  • 单例模式的四种创建方式

    单例模式是日常开发中最常见的一种设计模式,常用来做为池对象,或者计数器之类的需要保证全局唯一的场景。 单例模式的目的是保证在整个程序中只存在一个对象实例,使用单例一个前提条件就是构造器私有化,不允许通过new 对象的方式。单例模式的实现主要方式有如

    2024年02月01日
    浏览(43)
  • redis的四种模式优缺点

    Redis是一个完全开源的内存数据结构存储工具,它支持多种数据结构,以及多种功能。Redis还提供了持久化功能,可以将数据存储到磁盘上,以便在重启后恢复数据。由于其高性能、可靠性和灵活性,Redis被广泛应用于缓存、会话管理、排行榜、实时分析、消息队列等领域。

    2024年02月15日
    浏览(40)
  • SpringBoot项目启动后执行指定方法的四种实现

    今日的好天气 距离上一次更新帖子已经过了很久很久,久到我也不知道我在搞什么飞机。 国庆节第一天终于搬到了新家,最近量子纠缠比较火,冬天也在路上,匆匆又一年。 @PostConstruct是Java自带的注解,在方法上加该注解会在项目启动的时候执行该方法,也可以理解为在

    2023年04月15日
    浏览(41)
  • Docker的四种网络模式和相关网络命令

    docker 使用linux 桥接,在宿主机虚拟一个docker 容器网桥(docker0) ,docker 启动一个容器时会根据docker 网桥的网段分配给容器一个IP地址,称为Container-IP,同时Docker 网桥是每个容器的默认网关。因为在同一宿主机内的容器都接入同一个网桥,这样容器之间就能够通过容器的 Cont

    2024年02月05日
    浏览(41)
  • burp suite爆破的四种模式解析

    Sniper(狙击手模式): 如果爆破点设置一个,爆破字典是5条,那么就爆破5次 例如爆破点为一个 字典列表为(admin,admin@123,administrator,console,system)   如果爆破点为两个那么就爆破10次(两个爆破点依次爆破,比如两个爆破字段 账号和密码,先爆破账号字段(五次)在爆

    2024年02月13日
    浏览(31)
  • 解决iphone卡在恢复模式的四种方法

    比如系统升级的时候卡在恢复模式、降级系统、或者是在手机越狱过程中以及一些误操作可能手机就莫名其妙的进入到了iPhone恢复模式。 恢复模式在平时的应用主要是在iPhone连接电脑的时候,电脑无法识别到手机,我们将iPhone调至恢复模式就能够被电脑识别到了,之前我也分

    2024年02月10日
    浏览(137)
  • 微服务13-Seata的四种分布式事务模式

    XA模式分为两种情况 : 提交成功: 提交失败: 具有强一致性seata相当于是在RM上做了一层封装; XA模式 优点 : 1.事务的强一致性,只要有失败的,TC事务协调者就会发送信息让RM回滚——满足ACID原则 2.没有代码侵入,常用数据库都支持 缺点 : 1.第一阶段就要锁定数据库资源

    2024年02月07日
    浏览(42)
  • 【Kotlin 协程】Flow 流展平 ( 连接模式 flatMapConcat | 合并模式 flatMapMerge | 最新展平模式 flatMapLatest )

    Flow 流在 接收元素 时 , 可能需要 另一个 流的元素 , 两个流之间进行 交互的操作 就是 展平 , 常见的 展平模式有 : 连接模式 flatMapConcat : m 个元素的流 与 n 个元素的流 连接后 , 元素个数为 m x n 个 ; 合并模式 flatMapMerge : m 个元素的流 与 n 个元素的流 合并后 , 元素个数为 n x

    2023年04月08日
    浏览(42)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包