问题描述
我的代码基本上如下:
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 (将#修改为@)