如何在使用当前父 Scope 的“暂停乐趣”中启动 Kotlin 协程？

Question

如何从挂起函数启动协程并让它使用当前作用域？ （这样 Scope 在启动的协程也结束之前不会结束）

我想写一些类似下面的东西——

import kotlinx.coroutines.*

fun main() = runBlocking { // this: CoroutineScope
    go()
}

suspend fun go() {
    launch {
        println("go!")
    }
}

但这有一个语法错误：“未解决的参考：启动”。看来launch 必须以下列方式之一运行——

GlobalScope.launch {
    println("Go!")
}

或者

runBlocking {
    launch {
        println("Go!")
    }
}

或者

withContext(Dispatchers.Default) {
    launch {
        println("Go!")
    }
}

或者

coroutineScope {
    launch {
        println("Go!")
    }
}

这些替代方案都不能满足我的需要。代码“阻塞”而不是“生成”，或者它生成但父作用域不会在父作用域本身结束之前等待其完成。

我需要它在当前父协程作用域中“生成”（启动），并且该父作用域应该等待生成的协程完成后再结束。

我预计suspend fun 中的简单launch 将有效并使用其父范围。

我正在使用Kotlin 1.3 和cotlinx-coroutines-core:1.0.1。

Answer 1

你应该让函数go成为CoroutineScope的扩展函数：

fun main() = runBlocking {
    go()
    go()
    go()
    println("End")
}

fun CoroutineScope.go() = launch {
    println("go!")
}

阅读此article 以了解为什么不创建新的coroutineScope{} 就从suspend 函数和其他协程开始不是一个好主意。

约定是：在一个suspend函数调用其他suspend函数并创建一个新的CoroutineScope，如果你需要启动并行协程。结果是，只有当所有新启动的协程都完成（结构化并发）时，协程才会返回。

另一方面，如果你需要在不知道作用域的情况下启动新的协程，你创建一个CoroutineScope的扩展函数，它本身不是suspendable。现在调用者可以决定应该使用哪个范围。

Answer 2

我相信我找到了解决方案，即with(CoroutineScope(coroutineContext)。下面的例子说明了这一点——

import kotlinx.coroutines.*

fun main() = runBlocking {
    go()
    go()
    go()
    println("End")
}

suspend fun go() {
//  GlobalScope.launch {                     // spawns, but doesn't use parent scope
//  runBlocking {                            // blocks
//  withContext(Dispatchers.Default) {       // blocks
//  coroutineScope {                         // blocks
    with(CoroutineScope(coroutineContext)) { // spawns and uses parent scope!
        launch {
            delay(2000L)
            println("Go!")
        }
    }
}

不过，Rene 在上面发布了一个更好的解决方案。