并行执行协程并等待全部完成

Question

我有一个向 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 进行调用（都是挂起函数）之后，我通知 livedatas，但这需要一点时间（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]!!