Kotlin TestCoroutineDispatcher 在 yield() 之后挂在 cancelAndJoin() 上

问题描述

我的代码基本上如下:

var job: Job? = null

fun startJob() = runBlocking(dispatcher) {
    job = Coroutinescope(dispatcher).launch { myJob() }
}

suspend fun myJob() {
    // work block 1
    ...
    yield()

    // work block 2
    ...
    yield()

    // work block 3
    ...
    yield()
    ...
}

fun cancelJob() = runBlocking(dispatcher) {
    job?.cancelAndJoin()
}

fun main() {
    startJob()
    cancelJob()
}

当我使用 dispatcher = dispatchers.IO 或 dispatchers.Default 运行上面的代码时,它工作正常。然而,设置 dispatcher = TestCoroutinedispatchers 只是挂在 cancelAndJoin() 处。

我怀疑这与 TestCoroutinedispatcher 在处理 yield() 时的行为有关。根据 this,yield() 只有在调用 runcurrent() 时才会恢复。但鉴于我的代码结构,我不确定在哪里调用 runcurrent(),或者它是否是正确的方法

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)