如何用supervisorScope结合async并行请求并处理结果及异常？

核心问题修正与代码重构 #

首先需要明确两个关键问题的解决方式：异常的兜底处理、异步结果的作用域传递。以下是修复后的完整代码：

suspend fun getInfo() { 
    supervisorScope {
        // 启动两个并行的异步任务
        val firstDeferred = async { fetchFirstInfo() }
        val secondDeferred = async { fetchSecondInfo() }

        // 处理第一个任务的结果与异常
        val firstResult = try {
            firstDeferred.await()
        } catch(ex: Exception) {
            // 异常时返回兜底值，比如null或默认实例
            null
            // 示例：如果有默认对象可以写 FirstInfo()
        }

        // 处理第二个任务的结果与异常
        val secondResult = try {
            secondDeferred.await()
        } catch(ex: Exception) {
            // 同样提供兜底值
            null
            // 示例：SecondInfo()
        }

        // 在作用域内完成状态更新（因为结果变量仅在此作用域可见）
        state = state.copy(
            currentFirst = firstResult,
            currentSecond = secondResult,
        )
    }
}

// 模拟异步数据获取函数（根据实际业务替换）
suspend fun fetchFirstInfo(): FirstInfo { /* 业务逻辑 */ }
suspend fun fetchSecondInfo(): SecondInfo { /* 业务逻辑 */ }

关键细节说明 #

• 必须声明为挂起函数：supervisorScope是挂起函数，只能在挂起上下文或协程中调用，因此getInfo必须标记为suspend fun。
• 异常兜底逻辑：在try-catch的catch块中必须返回一个有效值（比如null或默认业务对象），确保firstResult和secondResult始终有值，避免后续状态更新出现未初始化问题。
• supervisorScope的优势：它保证了一个异步任务抛出异常时，不会取消其他并行的异步任务，两个任务可以独立完成执行与异常处理，这正是你需要的并行不干扰场景。
• 状态更新的位置：firstResult和secondResult是supervisorScope内部的局部变量，必须在此作用域内完成state.copy的赋值操作，外部无法访问这些变量。

内容的提问来源于stack exchange，提问作者Сергей Беляков