【Kotlin 协程】协程异常处理 ① ( 根协程异常处理 | 自动传播异常 | 在协程体捕获异常 | 向用户暴露异常 | 在 await 处捕获异常 | 非根协程异常处理 | 异常传播特性 )
2023-06-13 09:18:06 时间
文章目录
一、协程异常处理
在 协程任务 中 , 执行的代码出现异常 , 需要进行 异常处理 , 并给出错误提示信息 , 展示给用户 或者 上报服务器 ;
协程构建器 有两种 异常处理 形式 :
- 自动传播异常 : 使用 launch 或 actor 构建器 创建的 根协程 , 如果出现异常 , 会 马上抛出异常 ; 此类异常 在 可能出现异常的代码位置 进行捕获即可 ;
- 向用户暴露异常 : 使用 async 或 produce 构建器 创建的 根协程 , 如果出现异常 , 则需要 用户 通过 await 或 receive 来处理异常 ;
注意 : 下面讨论的情况是 根协程 的异常传播 ;
二、根协程自动传播异常
自动传播异常 : 使用 launch 或 actor 构建器 创建的 根协程 , 如果出现异常 , 会 马上抛出异常 ; 此类异常 在 可能出现异常的代码位置 进行捕获即可 ;
注意 : 下面讨论的情况是 根协程 的异常传播 ;
1、异常抛出点 ( 协程体抛出异常 )
launch 构建器 异常代码示例 : 使用 launch 构建器创建协程 , 在协程任务中抛出异常 , 查看异常的抛出点 ;
package kim.hsl.coroutine
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
class MainActivity : AppCompatActivity(){
val TAG = "MainActivity"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
// 将主线程包装成协程
runBlocking<Unit>{
val job = GlobalScope.launch {
throw ArithmeticException()
}
}
}
}执行结果 : 在第 19 行代码 , 也就是 throw ArithmeticException() 位置出现异常 , 说明 launch 构建器创建的协程抛出的异常是立即抛出 , 捕获异常也应该在该位置进行捕获 ;
23:48:34.849 E FATAL EXCEPTION: DefaultDispatcher-worker-1
Process: kim.hsl.coroutine, PID: 24394
java.lang.ArithmeticException
at kim.hsl.coroutine.MainActivity$onCreate$1$job$1.invokeSuspend(MainActivity.kt:21)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:571)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:678)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:665)
23:48:34.856 W Force finishing activity kim.hsl.coroutine/.MainActivity
---------------------------- PROCESS ENDED (24394) for package kim.hsl.coroutine -----------------------------------------------2、异常捕获点 ( 在协程体捕获异常 )
异常捕获代码示例 : 在协程任务代码中可能抛出异常的代码处捕获异常 ;
package kim.hsl.coroutine
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
class MainActivity : AppCompatActivity(){
val TAG = "MainActivity"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
// 将主线程包装成协程
runBlocking<Unit>{
val job = GlobalScope.launch {
try {
throw ArithmeticException()
}catch (e: Exception) {
e.printStackTrace()
}
}
}
}
}三、根协程向用户暴露异常
向用户暴露异常 : 使用 async 或 produce 构建器 创建的 根协程 , 如果出现异常 , 则需要 用户 通过 await 或 receive 来处理异常 ;
注意 : 下面讨论的情况是 根协程 的异常传播 ;
1、异常抛出点 ( 在 await、receive 处抛出异常 )
代码示例 : 在下面的代码中 , 如果不调用 async 构建的 Deferred 协程任务 的 await 方法 , 则不会报异常 ;
package kim.hsl.coroutine
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.async
import kotlinx.coroutines.runBlocking
class MainActivity : AppCompatActivity(){
val TAG = "MainActivity"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
// 将主线程包装成协程
runBlocking<Unit>{
val deferred = GlobalScope.async {
throw ArithmeticException()
}
}
}
}执行结果 :
2、异常捕获点 ( 在 await、receive 处捕获异常 )
代码示例 : 在 deferred.await() 代码处捕获异常 ;
package kim.hsl.coroutine
import android.os.Bundle
import android.util.Log
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.async
import kotlinx.coroutines.runBlocking
class MainActivity : AppCompatActivity(){
val TAG = "MainActivity"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
// 将主线程包装成协程
runBlocking<Unit>{
val deferred = GlobalScope.async {
throw ArithmeticException()
}
try {
deferred.await()
}catch (e: Exception) {
Log.i(TAG, "捕获到了异常")
e.printStackTrace()
}
}
}
}执行结果 :
四、非根协程异常处理
非根协程 , 也就是 子协程 的异常 会被传播 ;
代码示例 : 在子协程中产生的异常 , 会直接抛出 ;
package kim.hsl.coroutine
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.async
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
class MainActivity : AppCompatActivity(){
val TAG = "MainActivity"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
// 将主线程包装成协程
runBlocking<Unit>{
val job = GlobalScope.launch {
val deferred = async {
// 非根协程产生的异常, 直接抛出
throw ArithmeticException()
}
}
job.join()
}
}
}执行结果 :
00:01:14.870 E FATAL EXCEPTION: DefaultDispatcher-worker-2
Process: kim.hsl.coroutine, PID: 26818
java.lang.ArithmeticException
at kim.hsl.coroutine.MainActivity$onCreate$1$job$1$deferred$1.invokeSuspend(MainActivity.kt:21)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:571)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:678)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:665)
00:01:14.876 W Force finishing activity kim.hsl.coroutine/.MainActivity
00:01:14.883 I Sending signal. PID: 26818 SIG: 9
00:01:14.900 I Process kim.hsl.coroutine (pid 26818) has died: cch CRE
---------------------------- PROCESS ENDED (26818) for package kim.hsl.coroutine ----------------------------五、异常传播特性
协程 运行时 , 产生异常 , 会将异常 传递给 父协程 , 父协程会执行如下操作 :
- ① 取消子协程 : 不仅仅取消产生异常的子协程 , 该父协程下所有的子协程都会取消 ;
- ② 取消父协程 : 将父协程本身取消 ;
- ③ 向父协程的父协程传播异常 : 继续将异常传播给 父协程的父协程 ;
相关文章
- 开源 | 携程机票跨端 Kotlin DSL 数据库框架 SQLlin
- Kotlin（Java）与Golang的椭圆曲线密钥交换算法
- kotlin能否取代java(kotlin的历史以及现状)
- 【Kotlin】Kotlin 语言基础 ( 环境安装 | 变量 | 简单使用 | 函数 | 异常 | 递归 )
- 【Kotlin】Kotlin 构造函数 ( 主构造函数 | 主构造函数声明属性 | init 初始化代码块 | 次构造函数 | 构造函数委托 | 调用构造函数创建实例对象 )
- 【Kotlin 协程】协程底层实现 ④ ( 结构化并发 | viewModelScope 作用域示例 )
- 【Kotlin 协程】协程启动 ⑤ ( 协程作用域构建器 | runBlocking 函数 | coroutineScope 函数 | supervisorScope 函数 )
- 【Kotlin 协程】协程取消 ① ( 协程作用域取消 | 协程作用域子协程取消 | 通过抛出异常取消协程 | Job#cancel 函数 | 自定义异常取消协程 )
- 【Kotlin 协程】Flow 流组合 ( Flow#zip 组合多个流 | 新组合流的元素收集间隔与被组合流元素发射间隔的联系 )
- 【Kotlin】函数 ⑧ ( 函数引用 作为函数参数 | ::函数名 | 函数类型 作为函数返回值类型 )
- 【Kotlin】空安全 ③ ( 手动空安全管理 | 非空断言操作符 !! | 使用 if 语句判空 )
- 【Kotlin】空安全 ⑤ ( 异常处理 | 捕获并处理异常 | 抛出自定义异常 )
- 【Kotlin】空安全总结 ( 变量可空性 | 手动空安全管理 | 空安全调用操作符 | 非空断言操作符 | 空合并操作符 | 空指针异常处理 | 先决条件函数判空 )
- 【Kotlin】标准库函数总结 ( apply 函数 | let 函数 | run 函数 | with 函数 | also 函数 | takeIf 函数 | takeUnless 函数 )
- 【Kotlin】集合操作总结 ( List 集合 | MutableList 集合 | List 集合遍历 | Set 集合 | MutableSet 集合 | Map 集合 | 可变 Map集合 )
- 【Kotlin】接口和抽象类 ( 接口属性和方法定义 | 接口默认方法实现 | 抽象类 )
- 【Kotlin】泛型 ③ ( 泛型 out 协变 | 泛型 in 逆变 | 泛型 invariant 不变 | 泛型逆变协变代码示例 | 使用 reified 关键字检查泛型参数类型 )
- Kotlin之基本语法详解手机开发