kotlin - 如何在 Kotlin 中做并行 flatMap？

Question

我需要做平行平面图。假设我有这段代码:

val coll: List<Set<Int>> = ...
coll.flatMap{set -> setOf(set, set + 1)}

我需要这样的东西:

coll.pFlatMap{set -> setOf(set, set + 1)} // parallel execution

Answer 1

Kotlin 不提供任何开箱即用的线程。但是你可以使用 kotlinx.coroutines 来做这样的事情:

val coll: List<Set<Int>> = ...
val result = coll
 .map {set -> 
    // Run each task in own coroutine,
    // you can limit concurrency using custom coroutine dispatcher
    async { doSomethingWithSet(set) } 
 }
 .flatMap { deferred -> 
    // Await results and use flatMap
    deferred.await() // You can handle errors here
 }