是否有与 C# 等效的 Kotlin Task.WhenAll ?
我想出了下面的代码,但我想知道是否可以写whenAll
以便它只暂停一次。
fun main(args: Array<String>) = runBlocking {
println("Start")
val serviceA = KotlinServiceA()
val serviceB = KotlinServiceB()
val deferredA = async(CommonPool) { serviceA.operationA() }
val deferredB = async(CommonPool) { serviceB.operationB() }
var tasks = arrayOf(deferredA, deferredB)
tasks.whenAll()
println("End")
}
suspend fun Array<Deferred<Unit>>.whenAll() : Unit {
for (task in this) {
task.await()
}
}
最佳答案
有一个awaitAll()
完成工作的功能。
val deferredArray: Array<Deferred<Unit>> = arrayOf()
val awaitAllArray = awaitAll(*deferredArray)
如果您与
Collection
合作那么你可以使用 awaitAll()
扩展功能val deferredList: List<Deferred<Unit>> = listOf()
val awaitAllList = deferredList.awaitAll()
关于Kotlin 相当于 C# Task.WhenAll,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52799905/