废话很少说,直接上代码!git
GlobalScope.launch(Dispatchers.IO){
}.lifeRecycle(lifecycle) <<<<在这里
复制代码
没错就是这么简单。就是半行代码!github
lifecycle
。lifecycle.addObserver(LifecycleObserver)
复制代码
lifecycle.addObserver(object : LifecycleEventObserver {
override fun onStateChanged(source: LifecycleOwner, event: Lifecycle.Event) {
if (event == Lifecycle.Event.ON_DESTROY) {
//activity destroy
}
}
})
复制代码
因此我所实现的步骤就是经过观察activity的生命周期执行协程的cancel
函数。async
要使用这种方式不免要封装一下。ide
我看过网上有一个库RxLife-Coroutine 我细看了一下,他的方式有一些将协程本来的代码书写方式修改了。随也是一种方式,不过对于一些就项目不是很好的接入。函数
因而我灵鸡一动,想到不如用扩展函数。在不破坏源代码(这里的指的是现有使用协程的项目)的状况下,快速接入,一键完成生命周期的绑定。this
因此就有了这样的代码:spa
launch
使用GlobalScope.launch(Dispatchers.IO){
}.lifeRecycle(lifecycle) <<<<在这里
复制代码
async
使用GlobalScope.async(Dispatchers.IO){
}.lifeRecycle(lifecycle) <<<<在这里
复制代码
runBlocking
使用runBlocking(Dispatchers.IO) {
lifeRecycle(lifecycle) <<<<在这里
}
复制代码
withContext
使用withContext(Dispatchers.Main){
lifeRecycle(lifecycle) <<<<在这里
}
复制代码
有没有很简洁的样子code
我看了部分源码找到了这几个类 Job
,Deferred<T>
,CoroutineScope
cdn
Job
就是使用launch
函数的时候的返回值它持有cancel
函数server
Deferred<T>
继承自Job
public interface Deferred<out T> : Job {
//...
}
复制代码
CoroutineScope
是协程执行范围可在执行期间cancel
本身这个cancel
是CoroutineScope
的扩展函数
public fun CoroutineScope.cancel(cause: CancellationException? = null) {
//。。。。。。
}
复制代码
而咱们通用的几个协程函数取消的控制也就这几个能够控制,因此我找到了给谁扩展。
先给Job
扩展一个
fun Job.lifeRecycle(lifecycle: Lifecycle): Job {
return this
}
复制代码
就是这么简单,但为何要return
回去呢,为了避免破坏原代码的结构。减小异常的处理。
咱们要使用activity的lifecycle添加一个观察器
fun Job.lifeRecycle(lifecycle: Lifecycle): Job {
lifecycle.addObserver(object : LifecycleEventObserver {
override fun onStateChanged(source: LifecycleOwner, event: Lifecycle.Event) {
if (event == Lifecycle.Event.ON_DESTROY) {
cancelChildren()
cancel()
}
}
})
return this
}
复制代码
看是否是很简单!
个人思路很简单。代码量也不多。
我也写了一个相关的demo在GitHub上。有感兴趣的小伙伴能够一块儿探索,讨论。
最后贴两张所有代码图片