当您在协同程序作用域中抛出异常时，协同程序作用域是否可重用？

Question

我一直很难理解协同程序的错误处理，我已经通过以下步骤将其缩小到这个单元测试：

>

以下是测试：

fun `when you throw an exception in a coroutine scope, is the coroutine scope dead?`() {
    val parentJob = Job()
    val coroutineScope = CoroutineScope(parentJob + Dispatchers.Default)

    val deferredResult = coroutineScope.async { throw IllegalStateException() }

    runBlocking {
        try {
            deferredResult.await()
        } catch (e: IllegalStateException) {
            println("We caught the exception. Good.")
        }

        try {
            coroutineScope.async { println("we can still use the scope") }.await()
        } catch (e: IllegalStateException) {
            println("Why is this same exception still being thrown?")
        }

    }

}

下面是测试的输出：

We caught the exception. Good.
Why is this same exception still being thrown?

>

为什么会这样？

• 我的理解是，您可以正常处理异常，并通过协同程序从中恢复

我应该如何处理例外情况？

• 我需要创建一个新的合作项目吗
• 如果我想继续使用同一个coroutineScope，我就不能抛出异常吗
• 我应该返回吗

注意，我使用的是Kotlin 1.3




Answer 1

匿名用户

当您在某个范围内启动协同路由（使用async或launch）时，默认情况下，协同路由失败会取消该范围，以立即取消所有其他子项。这种设计避免了悬空和丢失异常。

这里的一般建议是：

>

除非确实需要并发，否则不要使用async/wait。当您使用挂起函数设计代码时，不需要太多地使用async和wait。

如果您确实需要并发执行，那么请遵循以下模式：

coroutineScope { 
    val d1 = async { doOne() }
    val d2 = async { doTwo() }
    ...
    // retrieve and process results
    process(d1.await(), d2.await(), .... )
}

如果您需要处理并发操作的失败，请在coroutineScope{...}周围放置try{...}cat{...}，以捕获任何并发执行操作中的失败。

• 还有其他高级机制（如SupervisorJob）允许细粒度异常处理。您可以在文档中阅读更多内容https://kotlinlang.org/docs/reference/coroutines/exception-handling.html