协程作用域概念迭代RxTask 实现自主控制
结合协程作用域概念迭代 RxTask 实现作用域功能
在过去的一段时间里有幸接触过某个项目，整体技术方案落后且线程滥用导致出现大量的内存泄漏或者资源反复耗费。原因在于这个项目中对 RxJava 创建操作不规范，反复创建线程且不及时消耗导致，刚好朋友在使用我的 RxTask 开源项目中也给我反馈一件事，能否提供一个类似像协程作用域概念，当被告知需要消耗时则及时把 RxTask 销毁。故此针对 RxTask 进行迭代升级有兴趣的同学可以了解下 RxTask 的设计及实现理念
作用域的设想及机制
熟悉 RxTask 的同学们都知道在原有的 RxTask 设计理念并没有存在 ITaskScope 这一概念，这一概念可以理解为限制当前创建的 RxTask 存活在某一对象中，当该对象被销毁时通过 ITaskScope 实例接口及时告知 RxTask 进行销毁操作。避免 RxTask 还在运行，譬如在 Android 环境中 Activity 运行一个异步 RxTask 由于Activity 在某些场景被销毁时，RxTask 来不及销毁仍然继续执行最终执行完成时回到 Activity 操作相关 UI 此时，则会报出异常从而导致崩溃或 RxTask 持续运行中不断消耗资源导致内存一直抖动，当然这都是因为开发者没有及时的控制好RxTask 出现的问题。为此提出 ITaskScope 概念，通过实现 ITaskScope 将 RxTask 与某个对象生命作用域进行关联从而及时进行销毁避免出现上诉问题。
接下来请看机制时序图：
从机制图中可以得到当 scope 处于销毁动作时则会告知 Task 对象让其取消执行，最后释放资源。
ITaskScope 的实现
那么 ITaskScope 接口定义如下
interface ITaskScope {
fun scopeOnDestroy()
fun subScope(callAction: ITaskScopeCallAction?)
}
interface ITaskScopeCallAction {
fun doOnScopeDestroyAction()
}
为什么在 ITaskScope 接口中会多出一个 ITaskScopeCallAction 接口呢？
其实同学可以这样理解 ITaskScope 仅仅负责在某个对象中持有单个或多 RxTask 对象，该对象处于销毁时期时及时调用 ITaskScope.scopeOnDestory() 方法去告知被持有 RxTask 对象们及时销毁，此刻为了避免 ITaskScope 对象会直接操作或联系 RxTask 对象那么，通过 ITaskScopeCallAction 去进行告知相关 RxTask 进行相应操作。
那么 ITaskScopeCallAction 仅仅负责处理销毁操作回调事件即可。
同学们还记得 RxTask 奠基石接口 ITask 吗？没错既然我们把 ITaskScope 、ITaskScopeCallAction 声明了那么，我们则需要利用 ITask 接口声明ITaskScope 绑定关系。
interface ITask<RESULT> {
//启动
fun start()
//取消
fun cancel()
fun bindScope(scope: ITaskScope?): ITask<RESULT>?
}
接下来再 RxTask 核心基类中实现关联关系即可：
abstract class ISuperTask<RESULT> : ITask<RESULT> {
protected var taskScope: ITaskScope? = null
protected var iTaskScopeCallAction: ITaskScopeCallAction = object : ITaskScopeCallAction {
override fun doOnScopeDestroyAction() {
cancel()
}
}
override fun bindScope(scope: ITaskScope?): ITask<RESULT>? {
scope?.subScope(iTaskScopeCallAction)
return this
}
}
基于 Android 平台拓展支持
熟悉 RxTask 库的同学们，都会清晰知道 RxTask 分为 libRxTask 及 libRxTaskAndroidExpand :
libRxTask 作为 RxTask 基准及核心实现并支持后端直接使用。
libRxTaskAndroidExpand 作为对 Android 平台进行拓展简单延伸的封装。
那么在 libRxTaskAndroidExpand 库中我们可以结合 Lifecycle 实现一个简单封装的 Scope 对象给同学们使用。
详细实现如下：
class RxTaskAndroidBasePageScope : ITaskScope, LifecycleEventObserver {
var canelByStopStatus = false
var cancelByPauseStatus = false
var cancelByDestroyStatus = true
private var observers: MutableList<ITaskScopeCallAction> = mutableListOf()
override fun scopeOnDestroy() {
observers.forEach { it?.doOnScopeDestroyAction() }
}
override fun subScope(callAction: ITaskScopeCallAction?) {
callAction?.let {
if (!observers.contains(it))
observers.add(it)
}
}
override fun onStateChanged(source: LifecycleOwner, event: Lifecycle.Event) {
when (event) {
Lifecycle.Event.ON_PAUSE -> {
if (cancelByPauseStatus) {
scopeOnDestroy()
return
}
}
Lifecycle.Event.ON_STOP -> {
if (canelByStopStatus) {
scopeOnDestroy()
return
}
}
Lifecycle.Event.ON_DESTROY -> {
if (cancelByDestroyStatus) {
scopeOnDestroy()
return
}
}
else -> {
}
}
}
}
那么使用如下(以 android 平台为例子)：
class MainActivity : AppCompatActivity() {
val scope = RxTaskAndroidBasePageScope()
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
lifecycle.addObserver(scope)
RxTaskAndroidDefaultInit.instant.defaultInit()
//
val task = object : SingleEvaluation<*> {
override fun evluation(task: RxSingleEvaluationTask<*>): Object {
//do your logic
return JsonObject()
}
}.getTask()
.bindScope(scope)
.start()
}
}
总结
写出一个库其实不难，难点在于如何理解通用性、简易性、拓展性、维护性，更重要的是需要虚心接受各方建议及反馈并进行修改，持续更新改进
以上就是协程作用域概念迭代RxTask 实现自主控制的详细内容，更多关于RxTask 自主控制的资料请关注脚本之家其它相关文章！
相关文章
对于现在的安卓手机而言,很多功能都是在逐步完善的,这篇文章主要给大家介绍了关于Android应用关闭的情况以及识别的相关资料,文章通过实例代码介绍的非常详细,需要的朋友可以参考下2022-06-06
这篇文章主要介绍了Android Flutter的实现原理是怎么样的，flutter可以说是当下最流行的跨平台技术了，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-08-08
本篇文章主要介绍了详细介绍Android中的视图焦点Focus的使用，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-01-01
在很多需要输入多行文本的应用（如记事本、编程代码编辑器、博客编辑器等）中,自动缩进功能能大大提升用户的编辑效率与体验,本文给大家介绍了Android实现EditText换行自动缩进功能,下面提供整合后的完整代码示例,需要的朋友可以参考下2025-04-04
Android使用CountDownTimer模拟短信验证倒计时
这篇文章主要为大家详细介绍了Android使用CountDownTimer模拟短信验证倒计时，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-07-07
这篇文章主要为大家详细介绍了Android实现获取联系人电话号码功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-03-03
这篇文章主要介绍了Android开发微信小程序页面的教程,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-10-10
Android编程开发之ScrollView嵌套GridView的方法
这篇文章主要介绍了Android编程开发之ScrollView嵌套GridView的方法,结合实例分析了ScrollView嵌套GridView的相关注意事项与处理技巧,需要的朋友可以参考下2015-12-12
这篇文章主要介绍了android银行卡号的验证算法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-09-09
这篇文章主要介绍了Android如何使用Glide加载清晰长图，帮助大家更好的理解和而学习使用Android开发，感兴趣的朋友可以了解下2021-03-03
最新评论