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

问题描述

我有两个在 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... 部分。实现这一目标的最佳方法是什么？

解决方法

同步并行协程有多种可能性。可能最简单的方法是创建一个单线程上下文，类似于主线程或使用 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)。

互斥：

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