一.保持对协程的追踪
我们知道协程可以处理耗时任务,但是假如我们的项目中开启了一千个协程处理任务,我们都是通过手动去追踪它们,那代码很容易出错。也很容易失去对协程的实时跟踪。就会引起work leak,任务泄漏,类似内存泄漏一样,任务泄漏会导致CPU,内存,磁盘资源被占用。甚至会发起一些无用的网络请求。为了避免任务的泄漏,Kotlin引入了结构化并发机制。
在Android平台使用结构化并发可以做到以下三件事:
(1)取消任务——当任务不需要继续执行的时候,取消他
(2)追踪任务——当任务正在执行的时候追踪他
(3)发出错误的信号——当协程执行失败时,发出错误信号表明有错误发生
二.借助scope 来取消任务
scope在协程中称为作用域,协程的运行必须指定作用域,CoroutineScope(作用域)可以对协程进行追踪,即使协程被挂起也是如此。CoroutineScope并不运行协程,他只是确保实时跟着协程的运行。因此在Kotlin中不允许在没有作用域的情况下启动新的协程。作用域可以跟踪所有的协程,有可以取消由它启动的协程。在Android开发中经常用到。比如在一个Activity中启动一个协程,当Activity关闭的时候,取消协程的执行。这个时候我们可以联想到让我们Activity的生命周期保持和作用域的生命周期一样。以上总结就是:作用域(CoroutineScope )会跟踪所有的协程,并可以取消由它启动的协程。
三.协程的启动方式
启动协程,必须要在作用域内,而启动协程的方式有两种:
(1)launch构建器——启动新的协程而不将结果返回给调用方
(2)async构建器——启动新的协程,通过await的挂起函数返回result
如:以下launch启动的协程,我们只是在挂起函数doSomthingOne中拿到了返回值。
package com.example.kotlin01
import kotlinx.coroutines.*
suspend fun main() {
runBlocking {
var job = launch {
var result1 = doSomthingOne()
println(result1)
}
}
}
suspend fun doSomthingOne(): Int {
delay(2000)
return 13
}
13
如:以下async启动的协程,我们通过返回调用await拿到返回值。
package com.example.kotlin01
import kotlinx.coroutines.*
suspend fun main() {
runBlocking {
var job = async {
doSomthingOne()
}
println(job.await())
}
}
suspend fun doSomthingOne(): Int {
delay(2000)
return 13
}
13
四.在 ViewModel 中启动协程
项目中经常我们通过使用jetpack中的ViewModel组件来作为View的控制器和Activity绑定起来,这样以来我们知道即使当我们的手机屏幕旋转Activity异常销毁重建的时候我们的Viewmodel也不会销毁。如果我们在ViewModel中启动协程,我们的协程也不会因此而被终止。我们知道协程都是运行在作用域中的,所以就产生了我们的ViewModel.viewModelScope。当viewModelScope被清除,调用onCleared的时候,我们的协程也就取消执行了。比如当一个接口正在请求数据的时候,此时用户关闭了应用,那么我们的请求就应该被取消掉。当一个协程中又启动了一个新的协程,那他们都公用父协程的作用域。viewModelScope的使用实例
package com.example.kotlin01
import androidx.lifecycle.ViewModel
import androidx.lifecycle.viewModelScope
import kotlinx.coroutines.launch
class MyViewModel : ViewModel() {
fun runForever() {
// 在 ViewModel 中启动新的协程
viewModelScope.launch {
// 当 ViewModel 被清除后,下列代码也会被取消
while (true){
println("你好")
}
}
}
}
我们看到我们在协程体中写了一个死循环,但是假如我们的Viewmodel被清除的时候,协程也会被取消。死循环中的代码也会取消执行。
五.任务追踪
有时候我们会遇到一些更复杂的问题,比如在一个协程中处理多个网络请求,我们可以作在一个协程中又启动多个协程去执行任务,但是如果随意启动协程,就会容易引起任务泄漏,调用方可能感知不到启动了新的协程,也就无法追踪。为了解决这个问题,结构化并发保证了supend函数返回时,处理任务也都完成。我们使用coroutineScope或者supervisorScope构造器在supend函数中启动新的协程,确保了supend函数返回的时候,他们所做的任务也都能结束。
suspend fun fetchTwoDocs() {
coroutineScope {
launch { fetchDoc(1) }
async { fetchDoc(2) }
}
}
以上suspend函数fetchTwoDocs中使用了coroutineScope构造器启动了两个协程,当fetchTwoDocs函数返回的时候,确保了launch和async启动的协程也都已经完成执行。
六.任务追踪(处理一堆任务)
在以上的例子中,假如我们在supend函数中启动了一千个协程,那么是否还能正常追踪呢,结果也是一样的。coroutineScope构造器启动的协程会等待协程中的任务执行完成,supend函数才会返回。并且coroutineScope还会创建一个子scope(作用域),我们知道supend函数肯定是由某个协程内部调用的,运行在某个作用域内,那么suspend函数中通过coroutineScope启动的协程会创建一个子作用域scope ,这个子作用域继承了suspend函数所在协程的作用域(父作用域)。假如这个父作用域是一个viewScope,当用户离开界面,关闭Activity的时候,viewScope被清除,那么所有的子作用域也会被清楚。子作用域内的协程也会被取消执行。这样就不会造成了任务泄漏。
七.协程失败时发出报错信号
val unrelatedScope = MainScope()
// 丢失错误的例子
suspend fun lostError() {
// 未使用结构化并发的 async
unrelatedScope.async {
throw InAsyncNoOneCanHearYou("except")
}
}
以上我们在supend函数中声明了一个无关联的作用域,它不会按照结构化并发的方式启动新的协程,这段代码的错误将丢失,因为异常通过去获取,而我们并没有调用await 。所以这个错误将永远不会得到处理。
使用结构化并发
suspend fun foundError() {
coroutineScope {
async {
throw StructuredConcurrencyWill("throw")
}
}
}
使用结构化并发就是在supend函数中使用coroutineScope构造器启动协程,coroutineScope将会创建子作用域继承了supend函数所在协程的作用域。如果coroutineScope创建的协程抛出了异常,coroutineScope将会抛给调用方,因为我们使用的是coroutineScope而不是supervisorScope,当抛出异常的时候,所有的子任务就会被取消。
八.理解结构化并发
package com.example.kotlin01
import kotlinx.coroutines.*
suspend fun main() {
println("${doSum()}")
}
suspend fun doSum(): Int = coroutineScope {
var result1 = async { doSomthingOne() }
var result2 = async { doSomthingTwo() }
result1.await() + result2.await()
}
suspend fun doSomthingOne(): Int {
delay(2000)
println("doSomthingOne")
return 13
}
suspend fun doSomthingTwo(): Int {
delay(1000)
println("doSomthingTwo")
return 15
}
在supend 函数中我们通过coroutineScope 构造器启动了两个协程调用doSomthingOne,doSomthingTwo,因为coroutineScope 启动的协程的作用域都继承了supend函数所在协程的作用域,当doSomthingOne函数出现异常的时候,会抛给父作用域,父作用域下协程的的子协程都会被取消。也就是doSomthingOne和doSomthingTwo都会被取消。