首页 > 解决方案 > 协程上下文自定义 getter

问题描述

我正在调查 1.0.0 发布后与 Android 相关的 kotlin 协程。

我发现了大量的例子,通过创建父作业并在其中清除它来制作作用域 ViewModel(来自拱组件)或使用在中创建作业并在中清除它的作用域onClearedActivity (与and相同)。在一些示例中,我遇到了这种代码结构(取自官方文档):onCreateonDestroyonResumeonPause

override val coroutineContext: CoroutineContext
        get() = Dispatchers.Main + job

当我们从这个范围启动一个新的协程时,这个自定义 getter 是否一直被调用?不是很糟糕吗?也许保留单个范围值而不是每次都创建一个新值会更好?

[更新]

我接受该解决方案,如果我们摆脱lateinit工作并立即创建它,但是如果我想做这样的事情怎么办(我应该怎么做?这个解决方案看起来是否正确?):

class LifecycleCrScope: CoroutineScope, LifecycleObserver {

  private var _job: Job? = null
  override val coroutineContext: CoroutineContext
    get() = job() + Dispatchers.Main


  fun job() : Job {
    return _job ?: createJob().also { _job = it }
  }

  fun createJob(): Job = Job() // or another implementation

  @OnLifecycleEvent(ON_PAUSE)
  fun pause() {
    _job?.cancel()
    _job = null
  }
}

标签: androidkotlinkotlinx.coroutines

解决方案


我认为当您在更新中提供一个懒惰的类似时,您可能会遇到线程安全问题,Job因为该代码是从发生在启动协程的任何线程中评估的。另一方面,初始示例确保作业是从主线程设置的,并且它发生在其他线程可以在典型的 android 活动中启动之前。

您可以通过在范围开始处创建整体来实现类似于初始示例的CoroutineContext效果。这也消除了为每个启动的协程计算最终上下文的需要。例如:

class LifecycleCrScope : CoroutineScope, LifecycleObserver {

    private var _ctx: CoroutineContext? = null
    override val coroutineContext: CoroutineContext
        get() = _ctx!! // throws when not within scope

    private fun startScope() {
        _ctx = Dispatchers.Main + Job()
    }

    private fun endScope() {
        _ctx!![Job]!!.cancel()  // throws only when misused, e.g. no startScope()
        _ctx = null
    }

    @OnLifecycleEvent(ON_RESUME) //  <-.
    fun resume() {               //    | Beware:
        startScope()             //    | symmetric but no scope
    }                            //    | during onCreate,
                                 //    | onStart, onStop, ...
    @OnLifecycleEvent(ON_PAUSE)  //  <-.
    fun pause() {
        endScope()
    }

}

或者,如果你不喜欢它扔

class LifecycleCrScope : CoroutineScope, LifecycleObserver {
    // initially cancelled. Jobs started outside scope will not execute silently
    private var _ctx: CoroutineContext = Dispatchers.Main + Job().apply { cancel() }
    ..
    private fun endScope() {
        _ctx[Job]!!.cancel()  // should never throw
    }
    ..

推荐阅读