结构化并发与协程生命周期管理

核心概念

结构化并发（Structured Concurrency）是 Kotlin 协程的基石，它强制协程拥有明确的作用域与生命周期。核心抽象包括：

• CoroutineScope —— 协程运行的上下文容器，控制其内部所有协程的集体生命周期。
• Job —— 每个协程返回的句柄，用于管理状态、等待完成、取消。
• Deferred —— 继承自 Job，带返回值的异步结果。

取消与超时是结构化并发的语义内建特性：取消一个父协程会自动取消其所有子协程；超时通过 withTimeout 或 withTimeoutOrNull 实现。

概念对比

概念	职责	生命周期	创建方式
CoroutineScope	提供协程上下文，管理子协程集体	显式取消或作用域结束	CoroutineScope(context)、GlobalScope、coroutineScope{}
Job	单个协程的句柄，控制状态与取消	从 New → Active → Completing → Completed	launch 返回值
Deferred	带结果的 Job	与 Job 相同，额外提供 await()	async 返回值
取消异常	协程被取消时抛出 CancellationException	正常取消时内部使用，用户可捕获处理	job.cancel() 触发

原理与实现流程

1. 创建作用域：通过 CoroutineScope(context) 或顶层挂起函数 coroutineScope {} 建立顶级容器。
2. 启动协程：在作用域内使用 launch（无返回值）或 async（有返回值），返回 Job / Deferred。
3. 协程执行：Job 进入 Active 状态，子协程自动变为作用域的子节点。
4. 取消操作：调用 job.cancel() 或 scope.cancel()，协程在下一次挂起点（如 delay、yield）抛出 CancellationException。
5. 超时退出：withTimeout(1000L) { ... } 超时后抛出 TimeoutCancellationException（继承自 CancellationException）。
6. 等待完成：job.join() 或 deferred.await() 阻塞挂起直到协程结束。

代码示例

import kotlinx.coroutines.*

fun main() = runBlocking {
    val scope = CoroutineScope(Dispatchers.Default + SupervisorJob())

    val job: Job = scope.launch {
        repeat(10) { i ->
            delay(100L)
            println("Working: $i")
        }
    }

    delay(250L)
    println("Cancelling job...")
    job.cancelAndJoin()
    println("Job cancelled")

    // 超时示例
    withTimeoutOrNull(500L) {
        delay(1000L)
        println("This won't print")
    } ?: println("Timeout occurred")
}

调试命令（查看协程状态）：在 JVM 启动参数添加 -Dkotlinx.coroutines.debug 可打印协程名与生命周期信息。

# 在 gradle 或命令行运行时添加：
-Dkotlinx.coroutines.debug

# 在代码中打印当前协程：
println("Current coroutine: ${coroutineContext[Job]}")

常见错误

• 未处理 CancellationException：在 try-catch 中捕获 Exception 而不重新抛出，导致协程无法正常取消。应捕获特定异常或重新抛出 CancellationException。
• 在 finally 块中挂起：取消后协程状态为 Cancelled，finally 中调用挂起函数（如 delay）会再次抛出 CancellationException。使用 withContext(NonCancellable) 强制运行。
• 忽略超时异常：withTimeout 默认抛出异常，应用层需处理或改用 withTimeoutOrNull。
• GlobalScope 滥用：GlobalScope 不与任何生命周期绑定，容易导致协程泄漏。应始终使用自定义作用域或 coroutineScope。

性能与优化建议

• 使用 SupervisorJob 作为父 Job，使子协程失败不影响同级协程（替代默认的 Job 传播取消）。
• 避免在 Dispatchers.Main 中执行大量 delay 或挂起操作，使用 Dispatchers.Default 或 IO 分流。
• 频繁创建取消作用域（如每帧）时，复用 CoroutineScope 实例，防止对象泄漏。
• 使用 ensureActive() 在循环中检查取消状态，避免无挂起点的长任务无法响应取消。

调试与验证

使用 CoroutineScope 的 coroutineContext[Job] 可获取当前协程的 Job 实例，检查其 isActive、isCancelled、isCompleted 状态。

val job = coroutineContext[Job]!!
println("Active: ${job.isActive}, Cancelled: ${job.isCancelled}, Completed: ${job.isCompleted}")