kotlin - 如何在特定点挂起协程

Question

我对以下问题不知所措。

我有以下代码:

val parentJob: Job = Job()

launch(parent = parentJob) {
    while (true)
    {
        if (!parentJob.isCompleted)
        {
            // I want to control suspension here
            println("Resumed")
        }
    }
}

我希望能够以某种方式类似于信号量来控制协程何时应该暂停以及何时在代码段的注释部分准确地恢复

我知道有 suspendCancellableCoroutine但我不确定如何使用它或在这里是否合适

这是如何实现的，或者是否有任何关于此的教程？

Answer 1

从回调和延续的角度考虑协程会更有帮助，而不是线程和信号量。

在内部，当协程挂起时，整个链suspend fun调用返回一个特殊的内部对象，COROUTINE_SUSPENDED .所以协程的整个执行只是一个函数调用，在此期间正在构建一个回调对象。这个回调是延续，当你调用它时，执行从返回特殊 COROUTINE_SUSPENDED 的地方恢复。目的。

Kotlin 运行您传递给 suspendCancellableCoroutine 的块以延续对象为参数。所以你应该保存这个对象并使其可用于协程之外的代码。

下面是一些可能有助于您理解的代码。请注意，如果要取消协程，则无需创建单独的父作业。您可以取消 Job实例 launch返回并且协程在暂停后不会恢复。

import kotlin.coroutines.*
import kotlinx.coroutines.*

var continuation: Continuation<String>? = null

fun main(args: Array<String>) {
    val job = GlobalScope.launch(Dispatchers.Unconfined) {
        while (true) {
            println(suspendHere())
        }
    }

    continuation!!.resume("Resumed first time")
    continuation!!.resume("Resumed second time")
    job.cancel()
    continuation!!.resume("This shouldn't print")
}

suspend fun suspendHere() = suspendCancellableCoroutine<String> {
    continuation = it
}

如果您仍然需要显式检查(因为执行路径上没有足够的暂停点)，您可以使用 isActive可直接用于块的属性:

while (isActive) ...