1、suspend 关键字进行标记强制从协程内调用函数
2、Kotlin 提供了三个调度程序,以用于指定应在何处运行协程:
-
Dispatchers.Main - 使用此调度程序可在 Android 主线程上运行协程。此调度程序只能用于与界面交互和执行快速工作。示例包括调用 suspend 函数,运行 Android 界面框架操作,以及更新 LiveData 对象。 -
Dispatchers.IO - 此调度程序经过了专门优化,适合在主线程之外执行磁盘或网络 I/O。示例包括使用 Room 组件、从文件中读取数据或向文件中写入数据,以及运行任何网络操作。 -
Dispatchers.Default - 此调度程序经过了专门优化,适合在主线程之外执行占用大量 CPU 资源的工作。用例示例包括对列表排序和解析 JSON。
例如,如果某个函数对一个网络进行十次调用,您可以使用外部 withContext() 让 Kotlin 只切换一次线程。这样,即使网络库多次使用 withContext(),它也会留在同一调度程序上,并避免切换线程。
3、可以通过以下两种方式来启动协程:
- launch 可启动新协程而不将结果返回给调用方。任何被视为“一劳永逸”的工作都可以使用 launch 来启动。
- async会启动一个新的协程,并允许您使用一个名为 await 的挂起函数返回结果。
通常,您应使用 launch 从常规函数启动新协程,因为常规函数无法调用 await。只有在另一个协程内时,或在挂起函数内且正在执行并行分解时,才使用 async。
4、launch 和 async 处理异常的方式不同。
由于 async 希望在某一时刻对 await 进行最终调用,因此它持有异常并将其作为 await 调用的一部分重新抛出。 这意味着,如果您使用 async 从常规函数启动新协程,则能以静默方式丢弃异常。 这些丢弃的异常不会出现在崩溃指标中,也不会在 logcat 中注明。
5、并行分解
在 suspend 函数启动的所有协程都必须在该函数返回结果时停止, 因此您可能需要保证这些协程在返回结果之前完成。 借助 Kotlin 中的结构化并发机制,您可以定义用于启动一个或多个协程的 coroutineScope。 然后,您可以使用 await()(针对单个协程)或 awaitAll()(针对多个协程)保证这些协程在从函数返回结果之前完成。
此外,coroutineScope 会捕获协程抛出的所有异常,并将其传送回调用方。
coroutineScope {
val deferreds = listOf(
async { fetchDoc(1) },
async { fetchDoc(2) }
)
deferreds.awaitAll()
}
6、Job 是协程的句柄。
使用 launch 或 async 创建的每个协程都会返回一个 Job 实例, 该实例是相应协程的唯一标识并管理其生命周期。 您还可以将 Job 传递给 CoroutineScope 以进一步管理其生命周期
val job = scope.launch {
}
7、CoroutineContext 使用以下元素集定义协程的行为:
- Job:控制协程的生命周期。
- CoroutineDispatcher:将工作分派到适当的线程。
- CoroutineName:协程的名称,可用于调试。
- CoroutineExceptionHandler:处理未捕获的异常。
8、避免使用 GlobalScope,生命周期与整个应用绑定,并且永远不会被主动取消。
这样启动的协程只有两个归宿:
- 协程正常执行完成
- 协程内部发生错误,导致协程因异常自动取消
可以考虑针对存在时间需要比当前作用域更长的工作注入一个 CoroutineScope。
9、协程取消属于协作操作
也就是说,在协程的 Job 被取消后, 相应协程在挂起或检查是否存在取消操作之前不会被取消。 如果您在协程中执行阻塞操作,请确保相应协程是可取消的。
例如,如果您要从磁盘读取多个文件,请先检查协程是否已取消, 然后再开始读取每个文件。若要检查是否存在取消操作, 有一种方法是调用 ensureActive 函数。
someScope.launch {
for(file in files) {
ensureActive()
readFile(file)
}
}
|