发布时间:2026/7/23 22:53:04
Kotlin 协程与结构化并发:Scope、Job 与取消 文章目录第 1 章 协程是什么轻量任务 结构化并发踩坑第 2 章 launch 与 async事件 vs 结果踩坑第 3 章 DispatcherMain / IO / Default踩坑第 4 章 取消与协作第 5 章 SupervisorJob子失败不拖垮全家第 6 章 异常处理与测试踩坑动手练练习 1launch vs asyncA · 基础练习 2GlobalScopeB · 进阶练习 3并行加载C · 综合练习 4withContextD · Android 实践练习 5SupervisorJobA · 基础练习 6取消协作B · 进阶进阶阅读可选追问链 #1coroutineScope 与 supervisorScope 追问链 #2viewModelScope 何时取消 追问链 #3Main.immediate 是什么 ⭐追问链 #4async 异常何时抛出 完整链路一句通相关推荐第 1 章 协程是什么轻量任务 结构化并发协程是可挂起的计算单元由调度器决定在哪个线程执行。与「裸线程」相比切换成本低与回调相比代码线性。结构化并发每个协程属于某个ScopeScope 取消时其下所有子协程一并取消——避免「飞出去的 async」泄漏。importkotlinx.coroutines.*funmain()runBlocking{coroutineScope{launch{delay(100);println(A)}launch{delay(50);println(B)}}println(scope 结束)}coroutineScope会等待子协程全部完成再返回。踩坑GlobalScope.launch无父 JobActivity 销毁后仍可能跑——禁止作为默认。第 2 章 launch 与 async事件 vs 结果构建器返回值典型用途launchJob发请求、更新状态不关心返回值asyncDeferredT并行计算最后await()取结果suspendfunloadSummary():StringcoroutineScope{valaasync(Dispatchers.IO){fetchA()}valbasync(Dispatchers.IO){fetchB()}${a.await()}${b.await()}}async仍在同一coroutineScope下任一子协程失败兄弟会被取消除非 Supervisor见第 5 章。Android 对照ViewModel 里刷新列表用viewModelScope.launch需要并行两个接口再在 suspend 函数内coroutineScope async。classTodoViewModel(privatevalrepo:TodoRepository,):androidx.lifecycle.ViewModel(){funrefresh(){viewModelScope.launch{valitemsrepo.loadAll()// 更新状态见《Flow 与 StateFlow》}}}踩坑在 Fragment 的lifecycleScope里做长耗时业务——应下沉到 ViewModel Repository。第 3 章 DispatcherMain / IO / DefaultDispatcher用途MainUI、轻量状态更新IO网络、磁盘、RoomDefaultCPU 密集计算Repository 用withContext(Dispatchers.IO)声明 IO 需求《suspend 与 Continuation》ViewModel 默认在 Main 更新状态。classTodoRepository{suspendfunloadAll():ListTodowithContext(Dispatchers.IO){// 网络或数据库emptyList()}}踩坑把所有阻塞 IO 塞Default应使用IO池。在Main上await长时间 IO 而不withContext阻塞 UI。第 4 章 取消与协作协程取消是协作式的挂起点delay、yield、suspend 函数会检查取消死循环里要自己ensureActive()或判断isActive。valjobscope.launch{repeat(1000){i-ensureActive()// 或 if (!isActive) returnlaunchdoStep(i)}}job.cancel()CancellationException是正常取消信号一般不要吞掉在finally里做清理时要注意是否因取消触发。第 5 章 SupervisorJob子失败不拖垮全家普通Job一个子协程未捕获异常会取消父 Job兄弟全停。SupervisorJob子失败不取消兄弟。valscopeCoroutineScope(SupervisorJob()Dispatchers.Main.immediate)scope.launch{launch{riskyAnalytics()}// 失败launch{refreshFeed()}// 仍可继续}viewModelScope内部使用SupervisorJob一个launch崩溃不应干掉同 ViewModel 其它任务——但仍应在子协程内runCatching转 UI 错误态。第 6 章 异常处理与测试viewModelScope.launch{valresultrunCatching{repo.load()}.getOrElse{e-// 转 UiState.Errorreturnlaunch}// Success 分支}测试 suspend 函数用runTestkotlinx-coroutines-test可控制虚拟时间无需真delay。踩坑async不await异常可能直到coroutineScope结束才抛出。吞掉CancellationException导致无法正确取消。动手练练习 1launch vs asyncA · 基础目标区分构建器。要求何时用launch何时用asyncawait()各一句。练习 2GlobalScopeB · 进阶目标理解结构化并发。要求说明GlobalScope.launch在 Activity 场景下的风险应用什么 Scope 替代。练习 3并行加载C · 综合目标coroutineScopeasync。要求写suspend fun loadPair(): PairInt, Int并行async { 1 }与async { 2 }后await。练习 4withContextD · Android 实践目标Repository IO。要求TodoRepository.load()用withContext(Dispatchers.IO)返回ListTodo函数体可emptyList()。练习 5SupervisorJobA · 基础目标子失败隔离。要求viewModelScope为何用SupervisorJob一句话。练习 6取消协作B · 进阶目标死循环退出。要求在while(true)循环里应加什么检查才能响应cancel()进阶阅读可选追问链 #1coroutineScope 与 supervisorScope 参考回答coroutineScope子失败取消全家supervisorScope用 Supervisor 语义子失败不取消兄弟。追问链 #2viewModelScope 何时取消 参考回答ViewModel.onCleared()时取消配置变更旋转不销毁 ViewModel协程可继续。追问链 #3Main.immediate 是什么 ⭐参考回答已在 Main 则立即执行不多一次调度viewModelScope常用组合。追问链 #4async 异常何时抛出 参考回答在await()时若从不 await可能在 scope 结束时传播。完整链路一句通Scope 界定生命周期→launch/async 发协程→withContext 声明线程需求→取消沿 Job 树传播→SupervisorJob 隔离并行任务→ViewModelScope 绑定界面逻辑寿命。相关推荐Kotlin 作用域函数let/apply 怎么选Kotlin 语法与空安全从零的第一课

相关新闻

2026/7/23 22:53:04

一封核查申请信件滞留多日,到底该由哪个科室签收受理?

6月29日,我寄出一封EMS快件,里面是一套案件相关的举证申请材料,希望院领导对21920号案件相关程序情况予以核查。此前在案件审理阶段,我申请以第三人身份参与诉讼,仅得到口头答复,并未出具书面意见。快递收件…

2026/7/23 22:48:03

Doker背景——服务器技术架构演进之路

目录 概述 常见概念 基本概念 应用/系统 模块(Module)/ 组件(Component) 分布式(Distributed) 集群(Cluster) 主(Master)/ 从(Slave&…

2026/7/23 22:48:03

400分钟短剧交付周期怎么估:AI译配全流程效率拆解短剧出海赶档期:为什么批量产能比单集处理速度更重要

AI短剧译配为什么不能只比低价:成本、质量和返工率一起算,看起来像一个价格或排期问题,实际是在问短剧出海团队能不能把内容生产做成可复制的流程。低价是预算表里最显眼的数字,但它不一定代表低成本。短剧译配的最终目标是可发布…

2026/7/24 0:18:11

计算机毕业设计之基于springboot的农村医疗健康管理系统的设计与实现

随着新世纪无纸化办公方式的普及,自动化信息处理和基于网络的信息交互方式已被广泛应用。现在很多行业基本上都是交由计算机进行管理和测试,网络与计算机已成为整个线上管理体系中的重要组成部分。虽然信息技术广泛应用和数据存取更加方便,但…

2026/7/24 0:18:11

本地大模型部署全攻略:从Ollama到企业级容器化

1. 本地大模型部署方式全景解析在AI技术快速发展的当下,本地部署大模型已成为企业数字化转型和个人开发者探索AI能力的重要选择。与云端API调用相比,本地部署能够提供更高的数据隐私性、更低的长期使用成本以及更灵活的定制空间。目前主流的本地部署方式…

2026/7/24 0:18:11

扩散模型与强化学习的融合:智能生成新范式

1. 扩散模型与强化学习的融合背景扩散模型近年来在生成式AI领域崭露头角,其通过逐步去噪的过程生成高质量样本的特性,使其在图像、音频等领域展现出惊人潜力。而强化学习(RL)作为决策优化的利器,在控制策略、游戏AI等场…

2026/7/24 0:13:11

基于深度强化学习的电池储能系统优化控制实践

1. 项目概述在能源转型的大背景下,电池储能系统(BESS)作为平衡电网供需的关键技术,其运行效率直接影响着整个电力系统的经济性和稳定性。传统基于规则的充放电策略往往难以应对复杂多变的电网环境,而深度强化学习(DRL)因其强大的环境适应能力…

2026/7/23 12:54:51

Unity与Python本地通信:基于Flask的跨语言数据交换实战

1. 项目概述:为什么我们需要一个本地通信服务器?在游戏开发、数字孪生、仿真训练等众多领域,Unity作为强大的实时3D内容创作平台,其核心逻辑通常由C#驱动。然而,当我们需要进行复杂的数据分析、机器学习推理、科学计算…

2026/7/24 0:03:10

不同品牌斜齿行星减速机如何替换?以PX与PAG系列为例

不同品牌斜齿行星减速机如何替换?以 PX 与 PAG 系列为例 一、系列对应不等于型号直接互换 PX 与 PAG 都属于斜齿、方法兰、输出轴式精密行星减速机,结构形式和应用方向具有对应关系。 原设备使用PX系列时,可以优先从PAG系列中寻找替换型号。但…

2026/7/24 0:03:10

jdk8 把list 扁平化成String 多个以逗号分隔

在 JDK 8 中&#xff0c;将 List 扁平化为以逗号分隔的 String&#xff0c;有几种非常简洁且高效的方法。&#x1f680; 推荐方案&#xff1a;使用 Collectors.joining()这是最标准的 Java 8 写法&#xff0c;适用于 List<String>。javaimport java.util.stream.Collecto…

2026/7/24 0:03:10

java 两个 long id 怎么合并成一个long id 并且不重复

“把两个 Long ID 合并成一个唯一的 Long ID&#xff0c;且保证不重复”这个需求&#xff0c;在 Java 里直接做数学上的“完美合并”是不可能的。因为两个 Long&#xff08;各 64 位&#xff09;要合并成一个 Long&#xff08;64 位&#xff09;&#xff0c;在信息论上是有损压…

2026/7/23 23:42:43

3个高效策略:快速掌握Axure中文界面配置

3个高效策略&#xff1a;快速掌握Axure中文界面配置 【免费下载链接】axure-cn Chinese language file for Axure RP. Axure RP 简体中文语言包。支持 Axure 11、10、9。不定期更新。 项目地址: https://gitcode.com/gh_mirrors/ax/axure-cn 还在为Axure RP的英文界面感…