如何取消收集协程StateFlow？答案

【问题标题】：How to cancel collect coroutine StateFlow?如何取消收集协程StateFlow？
【发布时间】：2021-07-27 16:26:22
【问题描述】：

我已经从片段中的共享视图模型收集流：

private val viewModel: MyViewModel by sharedViewModel()

private fun observeViewModelStateFlowData() {
job = lifecycleScope.launch {
            viewModel.stateFlowData.collect {
                when (it) {
                    is ViewStates.Success -> handleSuccess(it.data)
                }
            }
        }
    }

在 ViewModel 中：

private val _stateFlowData = MutableStateFlow<ViewStates<Model>>(ViewStates.Idle)
val stateFlowData: StateFlow<ViewStates<Model>> get() = _stateFlowData

但是当我转到下一个片段并再次回到这个片段时，再次收集流。我在片段的 onStop() 生命周期方法中取消了作业：

override fun onStop() {
    job?.cancel()
    super.onStop()
}

但不能取消并再次收集！！！

即使我离开活动（当视图模型被清除）并再次回到活动时也会发生这种情况！！！

我该怎么做才能防止流量聚集？

【问题讨论】：

onStop 只有在你替换片段时才会被调用，而不是在你使用 add 时。
您可以查看stackoverflow.com/a/68425325/9346054

标签： android kotlin-coroutines kotlinx.coroutines.flow

【解决方案1】：

嗯，你必须对协程有所了解。如果我们只是调用取消，并不意味着协程工作就会停止。如果您正在执行一些相对繁重的计算，例如从多个文件中读取，则没有什么可以自动阻止您的代码运行。

您需要确保您正在实施的所有协程工作都与取消协作，因此您需要定期或在开始任何长时间运行的工作之前检查取消。尝试在处理结果之前添加检查。

job = lifecycleScope.launch {
            viewModel.stateFlowData.collect {
                ensureActive()
                when (it) {
                    is ViewStates.Success -> handleSuccess(it.data)
                }
            }
        }
    }

欲了解更多信息，请查看这篇文章https://medium.com/androiddevelopers/cancellation-in-coroutines-aa6b90163629

【讨论】：