kotlin - 如何启动并行协程并返回结果

Question

我正在尝试编写一个异步运行2个操作并使用Kotlin协程返回结果的函数。例如，我希望自己的getData方法大致同时运行我的两个longRunningOperationX方法，以便我更快地得到合并的结果:

fun getData(): String {
  val stringOne = longRunningStringOperationOne()
  val stringTwo = longRunningStringOperationTwo()
  return stringOne + stringTwo
}

在Kotlin中，我可以使用launch和async方法运行这些操作。

fun getData(): String {
  GlobalScope.launch { 
    val stringOne = async { longRunningStringOperationOne() }
    val stringTwo = async { longRunningStringOperationTwo() }
    println("result: $stringOne + $stringTwo")
    // return "result: $stringOne + $stringTwo" <- not allowed
  }
  return "?"
}

但是，您可能知道，Coroutine范围内的操作结果无法在GlobalScope之外访问，因此，在长时间运行的操作完成之前，我的方法只需要返回当时的值即可。
那么，给定这个问题的空间-一个返回结果的非挂起(不是kotlin suspend fun)函数-我该如何异步(并行)运行两个长时间运行的操作，但是在返回结果之前使用Kotlin协程返回它们呢？

Answer 1

您将要使用Structured Concurrency代替Global Scope，并用await() async返回的Jobs。一种方法是这样的:

fun getData(): String {
  return runBlocking { 
    val stringOne = async { longRunningStringOperationOne() }
    val stringTwo = async { longRunningStringOperationTwo() }
    "result: ${stringOne.await()} + ${stringTwo.await()}")  // will be the return value of the runBlocking lambda
  }
}