防止同时执行两个挂起函数的一部分

Question

我有两个在ViewModel中并行启动的挂起方法：

init {
viewModelScope.launch(Dispatchers.Default) {
launch { loadTotalCirculation() }
launch { loadMarketPrice() }
}
}
private suspend fun loadTotalCirculation() {
val totalCirculation = bitcoinChartsRepository.getTotalCirculation(5, TimeUnit.HOURS)
_viewState.value = _viewState.value.copy(totalCirculation = chartViewEntityMapper(totalCirculation))
}
private suspend fun loadMarketPrice() {
val marketPrice = bitcoinChartsRepository.getMarketPrice(27, TimeUnit.DAYS)
_viewState.value = _viewState.value.copy(marketPrice = chartViewEntityMapper(marketPrice))
}

但是，我希望防止在我的两个方法中同时执行_viewState.value = _viewState.value.copy...部分。实现这一目标的最佳方式是什么？

Answer 1

同步并行协程有几种可能性。可能最简单的方法是创建一个单线程上下文，类似于主线程或使用Mutex。请注意，这个互斥对象是专门为例程设计的，它不是Java stdlib中的东西。

单线程上下文：

val context = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
private suspend fun loadTotalCirculation() {
val totalCirculation = bitcoinChartsRepository.getTotalCirculation(5, TimeUnit.HOURS)
withContext (context) {
_viewState.value = _viewState.value.copy(totalCirculation = chartViewEntityMapper(totalCirculation))
}
}
private suspend fun loadMarketPrice() {
val marketPrice = bitcoinChartsRepository.getMarketPrice(27, TimeUnit.DAYS)
withContext (context) {
_viewState.value = _viewState.value.copy(marketPrice = chartViewEntityMapper(marketPrice))
}
}

或者，您可以通过以下方式重用主线程，而不是创建自己的线程：withContext(Dispatchers.Main)。

Mutex：

val mutex = Mutex()
private suspend fun loadTotalCirculation() {
val totalCirculation = bitcoinChartsRepository.getTotalCirculation(5, TimeUnit.HOURS)
mutex.withLock {
_viewState.value = _viewState.value.copy(totalCirculation = chartViewEntityMapper(totalCirculation))
}
}
private suspend fun loadMarketPrice() {
val marketPrice = bitcoinChartsRepository.getMarketPrice(27, TimeUnit.DAYS)
mutex.withLock {
_viewState.value = _viewState.value.copy(marketPrice = chartViewEntityMapper(marketPrice))
}
}

使用主线程或互斥可能是首选，因为如果我们创建自己的线程，我们需要确保在不再需要它时正确地停止/关闭它。

您可以从官方文档中阅读本文中的更多内容：https://kotlinlang.org/docs/shared-mutable-state-and-concurrency.html