So looking at Coroutines for the first time, I want to process a load of data in parallel and wait for it to finish. I been looking around and seen RunBlocking and Await etc but not sure how to use it.
到目前为止，我已经做到了
val jobs = mutableListOf<Job>()
jobs += GlobalScope.launch { processPages(urls, collection) }
jobs += GlobalScope.launch { processPages(urls, collection2) }
jobs += GlobalScope.launch { processPages(urls, collection3) }
然后我想知道/等待这些完成
如果使用 struct 化并发的概念，则不需要手动跟踪当前作业(job).假设您的processPages函数执行某种阻塞IO，您可以将代码封装到以下挂起函数中，该函数在为此类工作设计的IO调度程序中执行您的代码:
suspend fun processAllPages() = withContext(Dispatchers.IO) {
// withContext waits for all children coroutines
launch { processPages(urls, collection) }
launch { processPages(urls, collection2) }
launch { processPages(urls, collection3) }
}
现在，如果应用程序的最顶层函数还不是挂起函数，则可以使用runBlocking调用processAllPages:
runBlocking {
processAllPages()
}