协程上下文自定义 getter

Question

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

我发现了很多通过创建父作业并在 onCleared 中清除它或在 onCreate 中创建作业并清除作用域 Activity 来制作作用域 ViewModel（来自 arch 组件）的示例在 onDestroy 中（与 onResume 和 onPause 相同）。在一些例子中，我遇到了这个代码结构（取自official docs）：

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

Answer 1

我认为当您像在更新中那样懒惰地提供 Job 时，您可能运行遇到线程安全问题，因为该代码是从碰巧启动协程的任何线程评估的。另一方面，初始示例确保作业是从主线程设置的，并且它发生在其他线程可以以典型的 android activity.

启动之前

您可以通过在作用域的开头创建整个 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
    }
    ..

协程上下文自定义 getter

Coroutine context custom getter

android

kotlin

kotlinx.coroutines