Kotlin 协程系统指南从入门到高级实战目标读者Android/Kotlin 开发者阅读目标不仅会“用 API”还要理解协程的设计思想、边界和工程落地方式。目录协程为什么出现先解决了什么问题协程核心概念全景图第一段协程代码逐行讲解suspend 的本质挂起不是阻塞作用域与生命周期结构化并发的入口Dispatcher 与线程切换策略并发组合launch/async/await 正确使用取消与超时可控结束比成功更重要异常传播与 Supervisor 思维模型Flow 入门什么是冷流Cold Flow冷流 vs 热流StateFlow/SharedFlow 全面对比Flow 常见操作符与背压处理Android 架构落地ViewModel RepositoryChannel 与 Actor协程间通信与串行化状态高级主题并发安全、性能优化、调试手段协程测试runTest、虚拟时间与可测性完整业务案例审批页并发加载 重试 超时 事件流常见误区与实践清单可直接贴团队规范1. 协程为什么出现先解决了什么问题1.1 传统线程模型的痛点线程创建和上下文切换成本高回调嵌套callback hell使代码难维护异步任务生命周期难统一管理容易泄漏错误处理分散try-catch 到处写1.2 协程提供的价值用“同步代码风格”表达异步逻辑轻量级并发可创建大量协程结构化并发保证任务生命周期可控配合 Flow/StateFlow 可自然描述 UI 数据流1.3 一个直观类比把“线程”想成“整间会议室”创建和切换都昂贵把“协程”想成“会议中的议程项”挂起时让出时间片成本很低。2. 协程核心概念全景图Coroutine可挂起可恢复的任务单元suspend标记可挂起函数CoroutineScope协程的生命周期容器Job协程句柄取消、状态跟踪Dispatcher运行调度器Main/IO/DefaultCoroutineContext上下文集合Job Dispatcher Name Handler可以先记住一句话协程 任务suspend 生命周期Scope/Job 执行策略Dispatcher3. 第一段协程代码逐行讲解importkotlinx.coroutines.*funmain()runBlocking{println(main start:${Thread.currentThread().name})valjoblaunch{println(child launch)delay(500)println(child done)}println(main waiting)job.join()println(main end)}说明runBlocking桥接普通函数与协程世界阻塞当前线程直到内部完成测试/示例常用launch启动无返回值协程delay挂起不阻塞线程join等待job完成4. suspend 的本质挂起不是阻塞4.1 什么是“挂起”挂起是当前协程暂时停下把线程让给别人等条件满足再恢复。4.2 生活类比你在餐厅点餐后不会一直站在柜台前堵住别人阻塞而是拿号去等挂起叫号再回来继续。4.3 代码示例suspendfunfetchUser():String{delay(300)returnTom}suspendfunloadPage(){valuserfetchUser()println(user$user)}4.4 常见误区suspend不是“自动异步线程切换”suspend函数内部如果做 CPU 重活且不切到Default依旧可能卡主线程5. 作用域与生命周期结构化并发的入口5.1 为什么必须有 Scope没有作用域就像“放飞无人机不设返航”任务何时结束、失败如何收口都不清楚。5.2 结构化并发原则子协程属于父协程父协程结束/取消子协程自动结束避免GlobalScope这种脱离生命周期的“野生协程”5.3 示例coroutineScopesuspendfunloadUserPage(repo:Repo):UserPagecoroutineScope{valprofileasync{repo.getProfile()}valpostsasync{repo.getPosts()}UserPage(profileprofile.await(),postsposts.await())}coroutineScope保证任何子任务失败整体感知并收敛。6. Dispatcher 与线程切换策略6.1 常见 DispatcherDispatchers.MainUI 更新Dispatchers.IO网络、文件、数据库Dispatchers.DefaultCPU 计算6.2 推荐线程策略ViewModel 层在MainRepository 做 IO 切换重计算切到Default6.3 示例suspendfunloadDetail(api:Api):DetailwithContext(Dispatchers.IO){api.getDetail()}suspendfuncalc(items:ListInt):IntwithContext(Dispatchers.Default){items.sum()}7. 并发组合launch/async/await 正确使用7.1 何时用 launch只关心执行不关心返回值如上报日志、触发事件7.2 何时用 async需要结果且可能并发等待多个结果7.3 页面并发加载示例suspendfunloadDashboard(api:Api):DashboardcoroutineScope{valprofileasync{api.profile()}valnoticesasync{api.notices()}valstatsasync{api.stats()}Dashboard(profileprofile.await(),noticesnotices.await(),statsstats.await())}7.4 注意async的异常在await()时抛出不要“创建了 async 却忘记 await”8. 取消与超时可控结束比成功更重要8.1 为什么取消重要App 页面退出、任务过时、用户主动中断都需要及时取消避免浪费资源。8.2 基础取消valjobscope.launch{repeat(10){delay(200)println(work$it)}}job.cancel()8.3 协作式取消CPU 任务scope.launch(Dispatchers.Default){while(isActive){// heavy compute}}8.4 超时valresultwithTimeoutOrNull(1000){api.longTask()}9. 异常传播与 Supervisor 思维模型9.1 默认传播模型在普通coroutineScope中某个子协程失败通常会取消同级。9.2CoroutineExceptionHandler适用范围主要对根launch有效async要在await处处理。9.3 Supervisor局部失败不拖垮全局valscopeCoroutineScope(Dispatchers.MainSupervisorJob())scope.launch{valalaunch{error(A fail)}valblaunch{delay(300);println(B still running)}joinAll(a,b)}适合场景页面多个模块并行加载某个模块失败不影响其他模块展示。10. Flow 入门什么是冷流Cold Flow10.1 定义冷流只有在被收集collect时才开始生产数据每个收集者都会触发一套新的生产过程。10.2 生活类比冷流像“点播视频”你点开才开始播放每个人点开都是自己的播放进度。10.3 示例证明“每次 collect 都重新执行”funtickerFlow()flow{println(flow start)repeat(3){delay(300)emit(it)}}scope.launch{tickerFlow().collect{println(collector A -$it)}}scope.launch{tickerFlow().collect{println(collector B -$it)}}你会看到flow start打印两次因为两次收集是两套独立执行。10.4 适用场景用户操作触发一次网络请求流需要“懒执行”数据处理流水线11. 冷流 vs 热流StateFlow/SharedFlow 全面对比11.1 什么是热流热流不依赖是否有人收集数据源可能一直在产生数据。生活类比热流像“广播电台”电台一直播听众随时加入冷流像“点播节目”你点开才播放11.2 三者定位Flow冷流按需执行StateFlow热流保存并提供“最新状态”SharedFlow热流广播事件可配置缓存/replay11.3 StateFlow 示例状态dataclassUiState(valloading:Booleanfalse,valdata:String?null,valerror:String?null)privateval_uiStateMutableStateFlow(UiState())valuiState:StateFlowUiState_uiStatefunsetLoading(){_uiState.value_uiState.value.copy(loadingtrue)}特点必须有初始值永远有最新值新订阅者会立刻拿到当前值11.4 SharedFlow 示例事件sealedinterfaceUiEvent{dataclassToast(valmessage:String):UiEventdataobjectNavigateBack:UiEvent}privateval_eventsMutableSharedFlowUiEvent(replay0,extraBufferCapacity1)valevents:SharedFlowUiEvent_eventssuspendfunsendToast(msg:String){_events.emit(UiEvent.Toast(msg))}特点适合一次性事件Toast、导航、弹窗可控制 replay/buffer 行为11.5 常见选择规则页面“状态” -StateFlow页面“一次性事件” -SharedFlow计算/请求流水线 -Flow12. Flow 常见操作符与背压处理12.1 常见操作符flowOf(1,2,3,4).map{it*2}.filter{it4}.onEach{println(emit$it)}.catch{e-println(error${e.message})}.collect()12.2 高频输入场景搜索框queryFlow.debounce(300).distinctUntilChanged().flatMapLatest{keyword-repository.search(keyword)}.collect{result-render(result)}解释debounce防抖distinctUntilChanged去重flatMapLatest只保留最新请求旧请求自动取消12.3 背压与处理策略buffer()生产和消费解耦conflate()只保留最新值跳过中间值collectLatest()来新值就取消上一次处理13. Android 架构落地ViewModel Repository13.1 推荐职责分层ViewModel状态与事件编排Repository数据获取与线程切换DataSource/API具体 IO 实现13.2 示例classApproveViewModel(privatevalrepository:ApproveRepository):ViewModel(){privateval_stateMutableStateFlow(ApproveUiState())valstate:StateFlowApproveUiState_stateprivateval_eventsMutableSharedFlowString()valevents:SharedFlowString_eventsfunload(procInsId:String){viewModelScope.launch{_state.update{it.copy(loadingtrue)}runCatching{repository.fetchDetail(procInsId)}.onSuccess{detail-_state.update{it.copy(loadingfalse,detaildetail)}}.onFailure{e-_state.update{it.copy(loadingfalse)}_events.emit(e.message?:加载失败)}}}}classApproveRepository(privatevalapi:ApproveApi){suspendfunfetchDetail(id:String):ApproveDetailwithContext(Dispatchers.IO){api.getDetail(id)}}14. Channel 与 Actor协程间通信与串行化状态14.1 Channel点对点/队列通信valchannelChannelInt(capacityChannel.BUFFERED)scope.launch{repeat(5){channel.send(it)}channel.close()}scope.launch{for(iteminchannel){println(receive$item)}}14.2 Actor把共享状态写入串行化sealedinterfaceCounterMsgobjectInc:CounterMsgclassGet(valreply:CompletableDeferredInt):CounterMsgfunCoroutineScope.counterActor()actorCounterMsg{varcount0for(msginchannel){when(msg){Inc-countisGet-msg.reply.complete(count)}}}适用高并发下避免锁竞争保证单线程顺序更新。15. 高级主题并发安全、性能优化、调试手段15.1 并发安全常见风险多个协程同时修改同一可变对象。解决方案不可变数据结构MutexActor 串行化valmutexMutex()varcounter0suspendfunsafeInc(){mutex.withLock{counter}}15.2 性能优化建议不要把小任务切成过多协程IO/CPU 任务严格分 Dispatcher减少无意义线程切换Flow 高频链路使用buffer/conflate/collectLatest15.3 调试建议JVM 参数开启调试-Dkotlinx.coroutines.debug协程命名CoroutineName(LoadApproveTimeline)关键节点打印currentCoroutineContext()信息16. 协程测试runTest、虚拟时间与可测性推荐依赖kotlinx-coroutines-testOptIn(ExperimentalCoroutinesApi::class)classApproveViewModelTest{Testfunload success updates state()runTest{valvmApproveViewModel(FakeApproveRepository(successtrue))vm.load(proc-1)advanceUntilIdle()assert(vm.state.value.loading.not())assert(vm.state.value.detail!null)}}关键点runTest替代runBlockingadvanceUntilIdle()推进虚拟时间测试中避免真实延迟和真实网络17. 完整业务案例审批页并发加载 重试 超时 事件流场景进入审批详情页并发请求三类数据允许瞬时失败重试总时长受控失败发事件提示。suspendfunloadApprovePage(procInsId:String):ApprovePageDatacoroutineScope{suspendfunTretry(times:Int2,block:suspend()-T):T{varlast:Throwable?nullrepeat(times1){try{returnblock()}catch(e:Throwable){lastedelay(200)}}throwlast?:IllegalStateException(unknown)}valdetailasync{withTimeout(3000){retry{approveApi.getDetail(procInsId)}}}valdictasync{withTimeout(3000){retry{dictApi.getApproveDict()}}}valtimelineasync{withTimeout(3000){retry{approveApi.getTimeline(procInsId)}}}ApprovePageData(detaildetail.await(),dictdict.await(),timelinetimeline.await())}这个例子同时体现结构化并发coroutineScope并发请求async超时withTimeout重试retry错误收敛await抛出18. 常见误区与实践清单可直接贴团队规范18.1 常见误区在业务层使用GlobalScope主线程执行 IO没有取消策略和超时策略把一次性事件塞进StateFlowasync创建后忘记awaitFlow 链路过长但无背压策略18.2 实践清单生命周期归属明确viewModelScope/lifecycleScopeRepository 统一withContext(Dispatchers.IO)状态用StateFlow事件用SharedFlow关键请求设置超时、重试、兜底对高频输入加debounce flatMapLatest测试统一runTest结语协程真正的难点不在 API 数量而在工程思维任务归属谁Scope跑在哪Dispatcher何时停取消/超时失败怎么办异常传播/Supervisor数据如何流动Flow/StateFlow/SharedFlow如果你愿意我下一步可以再给这份文档补两章“协程面试高频题附标准回答”“结合你当前screen/repository/utils目录的项目落地模板可直接复制”