在pararell中执行coroutines并等待全部完成

Question

我有一个viewmodel，它对API执行不同的请求，我现在是这样调用我的API的

        val call1 = repo.getCall1()
        val call2 = repo.getCall2()
        val call3 = repo.getCall3()
        val call4 = repo.getCall4()
        val call5 = repo.getCall5()
        val call6 = repo.getCall6()

这种方法的问题是，我需要等待每一个完成来启动另一个，在我对repo（都是挂起函数）执行此调用后，我通知livedata，但这需要一些时间（4-5秒），并且我希望同时执行所有调用，并在通知我的livedata之前一次捕获它们

我在找像这样的东西

myCoroutineScope.launch {

            call1 = repo.getCall1()
            call2 = repo.getCall2()
            call3 = repo.getCall3()
            call4 = repo.getCall4()
            call5 = repo.getCall5()
            call6 = repo.getCall6()
    }.awaitForAllToFinish()

我希望使用Async-Await而不是作业

Answer 1

如果所有调用的结果类型相同，则可以使用listof和awaitall执行此操作：

val results = listOf(
        async { repo.getCall1() }
        async { repo.getCall2() }
        async { repo.getCall3() }
        async { repo.getCall4() }
        async { repo.getCall5() }
        async { repo.getCall6() }
    ).awaitAll()

如果它们不是，我想您应该为每个变量保留变量。注意，与原始代码不同的是，这是并行运行它们的。

val call1 = async { repo.getCall1() }
val call2 = //...

val result1 = call1.await()
val result2 = call2.await()
// ...

// use the results

或者像你在第一个评论中建议的那样去做，也许像这样（没有检查）。但同样,如果结果类型不完全相同,这是不实际的。

val call1 = async { repo.getCall1() }
val call2 = //...

val jobs = listOf(call1, call2, call3, ...)
val resultsByJob = jobs.zip(jobs.awaitAll())

val result1 = resultsByJob[call1]!!