Kotlin中如何将List<Deferred<T>>转换为Deferred<List<T>>？

你当前的实现是挂起函数，会直接等待所有异步任务完成后返回最终结果列表。如果要实现类似Java CompletableFuture 那样返回一个代表整体结果的异步引用（Deferred<List<R>>），可以通过以下方式优化：

基础实现：返回Deferred<List> #

如果希望保持和原逻辑一致（任意任务失败则整体失败，并取消其他任务），可以扩展CoroutineScope来实现，让调用者控制协程上下文，避免潜在的协程泄漏：

fun <T, R> CoroutineScope.parallelMapAsync(elements: Iterable<T>, f: suspend (T) -> R): Deferred<List<R>> =
    async {
        elements.map { async { f(it) } }.awaitAll()
    }

优化点说明 #

• 用awaitAll()替代逐个调用await()：awaitAll()是Kotlin协程提供的高效API，一次性等待所有Deferred完成，代码更简洁，内部实现也比手动遍历await更高效。
• 由调用者提供CoroutineScope：避免在扩展函数内部创建默认协程作用域，让调用者可以根据场景指定调度器（比如CPU密集型用Dispatchers.Default，IO密集型用Dispatchers.IO），同时更好地控制协程生命周期。

如果要保持Iterable的扩展函数形式，也可以让调用者传入作用域：

fun <T, R> Iterable<T>.parallelMapAsync(scope: CoroutineScope, f: suspend (T) -> R): Deferred<List<R>> =
    scope.async {
        map { scope.async { f(it) } }.awaitAll()
    }

进阶实现：允许部分任务失败 #

如果需要类似Java中CompletableFuture.allOf的行为（即使部分任务失败，其他任务仍继续执行，最终返回所有结果的成功/失败状态），可以结合runCatching和Result类型：

fun <T, R> CoroutineScope.parallelMapAsync(elements: Iterable<T>, f: suspend (T) -> R): Deferred<List<Result<R>>> =
    async {
        elements.map { async { runCatching { f(it) } } }.awaitAll()
    }

这种实现下，每个任务的结果都会被包装成Result<R>，调用者可以后续遍历结果处理成功或失败的情况，不会因单个任务失败导致整个异步任务取消。

和原实现的区别 #

• 原实现是挂起函数，调用时会直接挂起直到所有任务完成，返回最终结果列表；
• 返回Deferred的版本是非挂起函数，调用后立即返回一个异步引用，调用者可以选择在合适的时机调用await()获取结果，或者和其他Deferred组合使用，灵活性更高。

内容的提问来源于stack exchange，提问作者Duncan McGregor