快捷導(dǎo)航

協(xié)程作用域概念迭代RxTask?實(shí)現(xiàn)自主控制

更新時間：2022年10月20日 14:07:54 作者：king@killer

這篇文章主要為大家介紹了協(xié)程作用域概念迭代RxTask實(shí)現(xiàn)自主控制詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

結(jié)合協(xié)程作用域概念迭代 RxTask 實(shí)現(xiàn)作用域功能

在過去的一段時間里有幸接觸過某個項目，整體技術(shù)方案落后且線程濫用導(dǎo)致出現(xiàn)大量的內(nèi)存泄漏或者資源反復(fù)耗費(fèi)。原因在于這個項目中對 RxJava 創(chuàng)建操作不規(guī)范，反復(fù)創(chuàng)建線程且不及時消耗導(dǎo)致，剛好朋友在使用我的 RxTask 開源項目中也給我反饋一件事，能否提供一個類似像協(xié)程作用域概念，當(dāng)被告知需要消耗時則及時把 RxTask 銷毀。故此針對 RxTask 進(jìn)行迭代升級有興趣的同學(xué)可以了解下 RxTask 的設(shè)計及實(shí)現(xiàn)理念

作用域的設(shè)想及機(jī)制

熟悉 RxTask 的同學(xué)們都知道在原有的 RxTask 設(shè)計理念并沒有存在 ITaskScope 這一概念，這一概念可以理解為限制當(dāng)前創(chuàng)建的 RxTask 存活在某一對象中，當(dāng)該對象被銷毀時通過 ITaskScope 實(shí)例接口及時告知 RxTask 進(jìn)行銷毀操作。避免 RxTask 還在運(yùn)行，譬如在 Android 環(huán)境中 Activity 運(yùn)行一個異步 RxTask 由于Activity 在某些場景被銷毀時，RxTask 來不及銷毀仍然繼續(xù)執(zhí)行最終執(zhí)行完成時回到 Activity 操作相關(guān) UI 此時，則會報出異常從而導(dǎo)致崩潰或 RxTask 持續(xù)運(yùn)行中不斷消耗資源導(dǎo)致內(nèi)存一直抖動，當(dāng)然這都是因?yàn)殚_發(fā)者沒有及時的控制好RxTask 出現(xiàn)的問題。為此提出 ITaskScope 概念，通過實(shí)現(xiàn) ITaskScope 將 RxTask 與某個對象生命作用域進(jìn)行關(guān)聯(lián)從而及時進(jìn)行銷毀避免出現(xiàn)上訴問題。

接下來請看機(jī)制時序圖：

從機(jī)制圖中可以得到當(dāng) scope 處于銷毀動作時則會告知 Task 對象讓其取消執(zhí)行，最后釋放資源。

ITaskScope 的實(shí)現(xiàn)

那么 ITaskScope 接口定義如下

interface ITaskScope {
    fun scopeOnDestroy()
    fun subScope(callAction: ITaskScopeCallAction?)
}
interface ITaskScopeCallAction {
    fun doOnScopeDestroyAction()
}

為什么在 ITaskScope 接口中會多出一個 ITaskScopeCallAction 接口呢？

其實(shí)同學(xué)可以這樣理解 ITaskScope 僅僅負(fù)責(zé)在某個對象中持有單個或多 RxTask 對象，該對象處于銷毀時期時及時調(diào)用 ITaskScope.scopeOnDestory() 方法去告知被持有 RxTask 對象們及時銷毀，此刻為了避免 ITaskScope 對象會直接操作或聯(lián)系 RxTask 對象那么，通過 ITaskScopeCallAction 去進(jìn)行告知相關(guān) RxTask 進(jìn)行相應(yīng)操作。

那么 ITaskScopeCallAction 僅僅負(fù)責(zé)處理銷毀操作回調(diào)事件即可。

同學(xué)們還記得 RxTask 奠基石接口 ITask 嗎？沒錯既然我們把 ITaskScope 、ITaskScopeCallAction 聲明了那么，我們則需要利用 ITask 接口聲明ITaskScope 綁定關(guān)系。

interface ITask<RESULT> {
    //啟動
    fun start()
    //取消
    fun cancel()
    fun bindScope(scope: ITaskScope?): ITask<RESULT>?
}

接下來再 RxTask 核心基類中實(shí)現(xiàn)關(guān)聯(lián)關(guān)系即可：

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 庫的同學(xué)們，都會清晰知道 RxTask 分為 libRxTask 及 libRxTaskAndroidExpand :

libRxTask 作為 RxTask 基準(zhǔn)及核心實(shí)現(xiàn)并支持后端直接使用。

libRxTaskAndroidExpand 作為對 Android 平臺進(jìn)行拓展簡單延伸的封裝。

那么在 libRxTaskAndroidExpand 庫中我們可以結(jié)合 Lifecycle 實(shí)現(xiàn)一個簡單封裝的 Scope 對象給同學(xué)們使用。

詳細(xì)實(shí)現(xiàn)如下：

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()
    }
}