当前位置: 首页 > article >正文

Kotlin 协程(三)协程的常用关键字使用及其比较

在使用协程时,经常会用到suspendlaunchasyncawaitwithContextrunBlocking这些关键字,这儿对其进行解释和比较

为了更好地理解 suspendlaunchasyncawaitwithContextrunBlocking 之间的区别,我们可以从 挂起、协程启动、作用域管理 等方面进行对比。

1. suspend 关键字(挂起与恢复)

  • suspend 关键字用于 定义挂起函数,表示该函数可以在非阻塞的情况下暂停(挂起)并恢复。
  • 挂起函数只能在 协程或其他挂起函数 中调用。
  • 挂起时不会阻塞线程,而是让出线程,允许其他协程执行。

2. launch(启动一个新的协程,返回 Job

  • launch 创建 并启动一个新的协程 但不会返回结果
  • 适用于 不需要返回值,例如更新 UI、写日志等。
  • 返回一个 Job,可以用 job.cancel() 取消该协程。

3. async & await(并发执行任务,返回 Deferred<T>

  • async 启动 并发任务 并返回一个 Deferred<T>(类似于 Future)。
  • await() 用于获取 async 返回的结果,如果任务未完成,它会挂起协程直到完成。
suspend fun loadData(): String {
    return withContext(Dispatchers.IO) {
        delay(1000)
        "Data loaded"
    }
}

suspend fun testAsync() {
    val deferred1 = async { loadData() }
    val deferred2 = async { loadData() }

    // await() 取出结果
    val result1 = deferred1.await()
    val result2 = deferred2.await()
    
    println("Result: $result1, $result2")
}
  • 需要 并行执行多个任务 并等待结果:
    • 多个网络请求
    • 批量数据库查询
    • 计算密集型任务

async 类似于 launch,但它返回结果launch 只是执行,不返回值。

4. withContext(切换协程上下文,执行完成后返回结果)

  • withContext 切换 到指定的调度器(线程池),执行代码块,并返回结果。
  • 等待代码块执行完成后再继续,不会创建新的协程,而是挂起当前协程并切换线程
suspend fun fetchData(): String {
    return withContext(Dispatchers.IO) {  // 切换到 IO 线程
        delay(1000)
        "Fetched Data"
    }
}
  • 切换线程池,适用于:
    • 网络请求(Dispatchers.IO
    • 数据库查询(Dispatchers.IO
    • 计算密集型任务(Dispatchers.Default

withContext 不会并发执行,它只是切换线程,等任务完成后再返回。

Dispatchers 预定义调度器

调度器作用适用场景
Dispatchers.Default适用于 CPU 密集型任务(计算、加密等)计算任务,如排序、数学运算等
Dispatchers.IO适用于 I/O 操作(磁盘、网络、数据库)读写文件、数据库查询、网络请求
Dispatchers.Main适用于 Android 主线程更新 UI,处理用户交互
Dispatchers.Unconfined继承调用方线程,恢复时可能切换线程测试或临时任务,不建议使用
newSingleThreadContext("MyThread")自定义单线程调度器特定线程执行任务

5. launch vs async vs withContext 对比

关键字是否返回结果适用场景线程调度
launch❌ 不返回结果执行任务但不关心结果不切换线程
async✅ 返回 Deferred<T>并发执行多个任务并等待结果不切换线程
withContext✅ 返回结果切换线程并执行任务切换线程

6.runBlocking 详解

runBlocking 是 Kotlin 协程中的一个函数,它 阻塞当前线程 并运行一个新的协程,直到该协程及其子协程执行完毕后才会继续执行后续代码。一般不会用到,只要用于测试

fun main() {
    runBlocking {
        println("协程开始")
        delay(1000)
        println("协程结束")
    }
    println("主线程继续执行")
}

执行流程

  1. runBlocking 启动 一个协程 并阻塞当前线程(如 main 线程)。
  2. delay(1000) 挂起协程,但 runBlocking 仍然阻塞 线程,其他代码不会执行。
  3. 协程执行完 delay(1000) 之后,继续执行 println("协程结束")
  4. runBlocking 结束后,主线程才会继续执行 println("主线程继续执行")
fun main() {
    runBlocking {
        launch {
            delay(1000)
            println("子协程完成")
        }
        println("runBlocking 结束")
    }
    println("主线程继续")
}

执行流程

  1. runBlocking 启动 一个主协程,阻塞 main 线程。
  2. launch 创建一个子协程,但 launch 不会阻塞 runBlocking,它只是异步执行。
  3. println("runBlocking 结束") 立即执行,不等待 launch 内部的 delay(1000)
  4. runBlocking 结束后main 线程继续执行 println("主线程继续")
  5. launch 子协程在后台继续运行,1 秒后打印 "子协程完成"

7.启动新协程

关键字作用返回值是否阻塞线程适用于
launch启动一个新的协程,异步执行代码Job❌ 否适合不需要返回值的任务
async启动一个新的协程,返回 DeferredDeferred<T>❌ 否适合需要返回值的任务

8. 作用域管理

关键字作用是否阻塞线程适用于
runBlocking阻塞当前线程,启动协程✅ 是main 函数、单元测试
coroutineScope创建新的协程作用域,等待所有子协程完成❌ 否挂起函数内部管理协程
withContext在指定调度器中切换上下文并执行代码❌ 否线程切换(如 IO 线程)

总结

关键字作用是否阻塞线程是否创建新协程适用于
suspend让函数支持挂起❌ 否❌ 否定义可挂起函数
launch启动一个协程,无返回值❌ 否✅ 是异步执行无返回值任务
async启动一个协程,返回 Deferred<T>❌ 否✅ 是计算任务,需要返回值
await挂起当前协程,等待 async 结果❌ 否❌ 否获取 async 结果
runBlocking启动协程并阻塞线程✅ 是✅ 是main 函数、测试
coroutineScope创建作用域,等待所有协程❌ 否❌ 否在挂起函数内部管理协程
withContext切换协程执行的线程❌ 否❌ 否线程切换,如 Dispatchers.IO


http://www.kler.cn/a/573759.html

相关文章:

  • Visual Stdio 2022 C#调用DeepSeek API
  • HCIA—IP路由静态
  • koa-session设置Cookie后获取不到
  • C#调用Ni板卡进行实现采集任务(模拟量输入输出)示例1
  • 涨薪技术|持续集成Git使用详解
  • 机器人“照镜子”:开启智能新时代
  • Apache Tomcat 新手入门指南:从安装到部署的全流程解析
  • 高频 SQL 50 题(基础版)_1141. 查询近30天活跃用户数
  • leetcode344----反转字符串
  • 正则表达式梳理(基于python)
  • 学习记录-缺陷
  • 2.数据结构:7.模拟堆
  • AI绘画软件Stable Diffusion详解教程(5):主模型的选择
  • 数据守护者:备份文件的重要性与自动化实践策略
  • 面试题汇总(一)
  • 将自定义vue组件加载在Mapbox或Maplibre的marker和popup上
  • SpringBoot3—场景整合:NoSQL
  • 开源模型应用落地-LangGraph101-探索 LangGraph人机交互-添加断点(一)
  • 准确---Liunx查看出口ip的命令
  • Leetcode 57: 插入区间