半行代码绑定协程生命周期
纯属娱乐！
废话不多说，直接上代码！
GlobalScope.launch(Dispatchers.IO){
}.lifeRecycle(lifecycle) <<<<在这里
没错就是这么简单。就是半行代码！
先说一下原理
在AndroidX中Activity的生命周期的监听可以使用lifecycle。
lifecycle.addObserver(LifecycleObserver)
使用这个观察者监听当前activity的生命周期变化。
lifecycle.addObserver(object : LifecycleEventObserver {
override fun onStateChanged(source: LifecycleOwner, event: Lifecycle.Event) {
if (event == Lifecycle.Event.ON_DESTROY) {
//activity destroy
}
}
})
所以我所实现的步骤就是通过观察activity的生命周期执行协程的cancel函数。
要使用这种方式难免要封装一下。
我看过网上有一个库RxLife-Coroutine 我细看了一下，他的方式有一些将协程原本的代码书写方式修改了。随也是一种方式，不过对于一些就项目不是很好的接入。
于是我灵鸡一动，想到不如用扩展函数。在不破坏源代码(这里的指的是现有使用协程的项目)的情况下，快速接入，一键完成生命周期的绑定。
所以就有了这样的代码：
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) <<<<在这里
}
有没有很简洁的样子
我是这么做的
1.要先找到给谁扩展
我看了部分源码找到了这几个类 Job,Deferred<T>,CoroutineScope
Job就是使用launch函数的时候的返回值它持有cancel函数
Deferred<T>继承自Job
public interface Deferred<out T> : Job {
//...
}
CoroutineScope 是协程执行范围可在执行期间cancel自己这个cancel是CoroutineScope 的扩展函数
public fun CoroutineScope.cancel(cause: CancellationException? = null) {
//。。。。。。
}
而我们通用的几个协程函数取消的控制也就这几个可以控制，所以我找到了给谁扩展。
2.如何扩展
先给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上。有感兴趣的小伙伴可以一起探索，讨论。
最后贴两张全部代码图片
网友评论