在 Kotlin 中,协程提供了一种更简洁、更安全的方式来处理异常。协程使用 try-catch
块来捕获和处理异常,就像在普通的函数中一样。但是,协程还提供了一种特殊的异常类型 CoroutineException
,它可以在协程的作用域内抛出和捕获。
以下是一个使用 Kotlin 协程处理异常的示例:
import kotlinx.coroutines.* fun main() = runBlocking { try { // 启动一个协程 val result = async { throw ArithmeticException("division by zero") // 这里的代码永远不会被执行 42 } // 获取协程的结果 println(result.await()) } catch (e: ArithmeticException) { // 捕获并处理异常 println("Caught exception: ${e.message}") } catch (e: Exception) { // 捕获并处理其他类型的异常 println("Caught exception: ${e.message}") } }
在这个示例中,我们使用 async
函数启动了一个协程,并在其中抛出了一个 ArithmeticException
异常。然后,我们使用 await
函数获取协程的结果,并使用 try-catch
块捕获和处理异常。
注意,当使用 async
函数时,如果协程抛出异常,它将被封装在 CoroutineException
中。因此,在 catch
块中,我们需要捕获 CoroutineException
并从中提取原始异常。我们可以使用 e.cause
属性来获取原始异常。
此外,我们还可以使用 CoroutineExceptionHandler
接口来处理协程中的未捕获异常。这可以在协程的作用域之外进行设置,例如在 runBlocking
或 launch
函数中。以下是一个使用 CoroutineExceptionHandler
的示例:
import kotlinx.coroutines.* fun main() = runBlocking { // 创建一个 CoroutineExceptionHandler val handler = CoroutineExceptionHandler { _, exception -> println("Caught exception: ${exception.message}") } // 启动一个协程,并将其与 CoroutineExceptionHandler 关联 val result = async(handler) { throw ArithmeticException("division by zero") // 这里的代码永远不会被执行 42 } // 获取协程的结果 println(result.await()) }
在这个示例中,我们创建了一个 CoroutineExceptionHandler
,并将其传递给 async
函数。当协程抛出异常时,处理器将捕获并处理异常。