日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

協程作用域概念迭代RxTask?實現自主控制_Android

作者：king@killer ? 更新時間： 2022-11-28 編程語言

結合協程作用域概念迭代 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()
    }
}

總結

寫出一個庫其實不難，難點在于如何理解通用性、簡易性、拓展性、維護性，更重要的是需要虛心接受各方建議及反饋并進行修改，持續更新改進

原文鏈接：https://juejin.cn/post/7155791036114010148

欄目分類
最近更新