如何解决防止同时执行两个挂起函数的一部分
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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。