Kotlin协程等待多任务完成时的异常处理与等待失效问题

看起来你遇到了Kotlin协程并行任务里异常处理和等待逻辑的典型坑，我来帮你梳理清楚问题根源和解决办法。

先分析你遇到的两个问题 #

1. 单个子协程抛异常导致整个订阅器崩溃
   这是因为默认协程作用域（比如coroutineScope）的特性：只要有一个子协程抛出未捕获的异常，它会立刻取消所有其他子协程，并且把异常传播到父协程，最终导致整个订阅器的协程上下文崩溃。哪怕是CancellationException，默认情况下也会触发这个连锁反应。

2. 加try-catch后主协程没等所有任务完成
   大概率是你只针对性捕获了那个“有问题”子协程的异常，但没做到等待所有任务的最终状态。或者更常见的情况：当那个子协程抛出CancellationException时，父协程被触发取消，虽然其他任务还在后台跑，但主协程已经提前退出了，所以你看不到它们完成的日志。

核心解决思路 #

要同时满足「单个任务失败不影响全局」和「必须等待所有任务完成」，需要做到两点：

• 隔离子协程的异常传播：让单个任务的失败不会连累其他任务或父协程
• 强制等待所有任务结束：不管任务是成功、失败还是被取消，主协程都要等它们跑完

具体代码实现方案 #

推荐用supervisorScope来实现异常隔离，再配合逐个等待所有Deferred对象的方式：

// 假设这是你的订阅器处理逻辑所在的协程
supervisorScope {
    // 启动所有并行任务，收集每个任务的Deferred对象
    val tasks = listOf(
        async {
            delay(500)
            throw CancellationException("任务A主动取消")
        },
        async {
            delay(10000)
            println("B finished")
            "B执行成功"
        },
        async {
            delay(5000)
            println("C finished")
            "C执行成功"
        }
    )

    // 遍历所有任务，逐个等待并处理异常
    tasks.forEach { deferred ->
        try {
            val result = deferred.await()
            // 这里可以处理任务成功的结果（如果需要）
            println("任务完成结果：$result")
        } catch (e: CancellationException) {
            println("任务被取消：${e.message ?: "未知原因"}")
        } catch (e: Exception) {
            println("任务执行失败：${e.message ?: "未知异常"}")
        }
    }
}

println("所有任务都已处理完毕，订阅器可以继续下一轮消息处理")

代码解释 #

• supervisorScope的作用：它是专门用来隔离子协程异常的作用域——某个子协程抛出异常时，不会取消其他子协程，也不会自动把异常传播给父协程，完美解决“一个任务崩了连累全局”的问题。
• 逐个await并捕获异常：确保主协程会等待每一个任务的最终状态，哪怕任务失败或被取消，也不会中断等待其他任务的流程。
• 异常分类处理：区分CancellationException和普通异常，能更精准地处理不同类型的任务状态。

简化版（不需要处理单个任务结果） #

如果你只需要等待所有任务完成，不需要获取每个任务的结果，可以用joinAll()替代逐个await，代码更简洁：

supervisorScope {
    val tasks = listOf(
        async { ... },
        async { ... },
        async { ... }
    )
    tasks.joinAll() // 等待所有任务完成，不管成功/失败/取消
    println("所有任务都执行完了")
}

备注：内容来源于stack exchange，提问作者BVtp