解释 kotlin 协程死锁的原因

Question

在尝试使用 kotlin 协程时，我遇到了一个我没想到会发生死锁的情况。

我将代码简化为以下显示问题的最小代码示例：

@Test
    fun deadlockTest() {
        runBlocking {
            val job = launch {
                runBlocking {
                    println("await cancellation")
                    awaitCancellation()
                }
            }
            println("launched job")
            delay(100)
            println("waited a bit")
            job.cancelAndJoin()
            println("canceled and joined")
        }
        assertTrue(true)
    }

结果是

launched job
await cancellation
waited a bit

它永远不会超出job.cancelAndJoin，好像有一些死锁一样。

如果我将代码稍微更改为以下内容：

@Test
    fun fixedDeadlockTest() {
        runBlocking {
            val job = launch {
                withContext(Dispatchers.Default) { // <-- this is the only difference
                    println("awaiting cancellation")
                    awaitCancellation()
                }
            }
            println("launched job")
            delay(100)
            println("waited a bit")
            job.cancelAndJoin()
            println("canceled and joined")
        }
        assertTrue(true)
    }

一切正常，所有行都被打印出来，测试完成。

问题是：为什么这段代码会导致死锁，将一个 runBlocking 放在另一个 runBlocking 的启动中是不是一种不好的做法？ （即在您的代码中永远不要使用 runBlocking，直到您从非协程范围内实际启动协程？）

我使用了以下版本：

• kotlin 多平台 1.4.32
• kotlinx-coroutines-core 版本 1.5.0-native-mt

Answer 1

协程使用所谓的结构化并发来支持取消、异常处理等。它们被结构化为作业树，因此通常当您创建新的协程时，它们会成为当前协程的子级。父母和孩子之间有特定的责任，例如取消父级会取消其所有子级。

但是，有一些方法可以启动未附加到当前协程的协程。发生这种情况，例如如果您提供特定的CoroutineScope 或者如果您使用runBlocking()。请注意，与launch() 或async() 不同，runBlocking() 不需要从协程运行。它的设计主要是为了桥接非协程和协程代码，因此它从“根”开始创建协程——它们与其他协程分离。

由于上述原因，您的示例中的cancelAndJoin() 取消了在launch() 内部运行的协程，但它不会取消在runBlocking() 内部运行的协程。 “awaitCancellation”协程与“launch”协程分离，因此它忽略了它的取消。

以下是我的原始答案。我对这个僵局的主要原因是错误的，但我所说的仍然大部分是正确的，它补充了上面的答案，所以我保持原样。我错的原因是我忘记了runBlocking()在内部使用了一个线程局部变量来存储它的事件循环。这意味着在另一个runBlocking() 中运行的runBlocking() 实际上共享相同的事件循环/调度程序，因此通过在awaitCancellation() 暂停它可以从delay() 恢复。不过，我认为不鼓励这样做。

原答案：

发生死锁是因为外部runBlocking() 启动了一个单线程协程调度程序以在其中启动协程，而内部runBlocking() 阻塞了这个唯一的线程。

你是对的，runBlocking() 主要用于桥接非协程和协程代码。没有硬性规定禁止在协程内部使用runBlocking()，但通常我们应该避免在协程内部阻塞，而是应该暂停。 runBlocking() 阻止，因此不鼓励这样做，可能会导致上述后果。