如何在 MainActivity 中等待直到完成来管理协程?
How to manage coroutines in MainActivity with waiting until done?
我在 MainActivity
中使用 GlobalScope
和 runBlocking
,但我不使用流只是暂停功能。我想将 GlobalScope
从协程更改为其他范围。
用例
class UpdateNotificationListItemUseCase @Inject constructor(private val notificationDao: NotificationDao): BaseUpdateBooleanUseCase<Int, Boolean, Boolean, Boolean, Unit>() {
override suspend fun create(itemId: Int, isRead: Boolean, isArchived: Boolean, isAccepted: Boolean){
notificationDao.updateBooleans(itemId, isRead, isArchived, isAccepted)
}
}
主要活动
val job = GlobalScope.launch { vm.getIdWithUpdate() }
runBlocking {
job.join()
}
主视图模型
suspend fun getIdWithUpdate() {
var id = ""
id = notificationAppSessionStorage.getString(
notificationAppSessionStorage.getIncomingKeyValueStorage(),
""
)
if (id != "") {
updateNotificationListItemUseCase.build(id.toInt(), true, false, false)
}
}
}
我的主张:
我已阅读文档https://developer.android.com/kotlin/coroutines/coroutines-best-practices
val IODispatcher: CoroutineDispatcher = Dispatchers.IO
val externalScope: CoroutineScope = CoroutineScope(IODispatcher)
suspend {
externalScope.launch(IODispatcher) {
vm.getIdWithUpdate()
}.join()
}
第二个选项,但这里我不等到工作完成
suspend {
withContext(Dispatchers.IO) {
vm.getIdWithUpdate()
}
}
你怎么看?
不是提供给ANR吗,我也阻塞线程了。
您可以在 MainActivity
中使用 lifecycleScope
而不是 GlobalScope
来启动协程:
lifecycleScope.launch {
vm.getIdWithUpdate() // calling suspend function
// here suspend function `vm.getIdWithUpdate()` finished execution
// ... do something after suspend function is done
}
要使用lifecycleScope
添加依赖:
implementation 'androidx.lifecycle:lifecycle-runtime-ktx:.4.0'
强烈建议不要使用 GlobalScope
。而且不需要调用job.join()
,你可以在调用vm.getIdWithUpdate()
之后在coroutine builder block中做一些事情,比如更新UI。此协程是 运行 使用 Dispatchers.Main
上下文。
我在 MainActivity
中使用 GlobalScope
和 runBlocking
,但我不使用流只是暂停功能。我想将 GlobalScope
从协程更改为其他范围。
用例
class UpdateNotificationListItemUseCase @Inject constructor(private val notificationDao: NotificationDao): BaseUpdateBooleanUseCase<Int, Boolean, Boolean, Boolean, Unit>() {
override suspend fun create(itemId: Int, isRead: Boolean, isArchived: Boolean, isAccepted: Boolean){
notificationDao.updateBooleans(itemId, isRead, isArchived, isAccepted)
}
}
主要活动
val job = GlobalScope.launch { vm.getIdWithUpdate() }
runBlocking {
job.join()
}
主视图模型
suspend fun getIdWithUpdate() {
var id = ""
id = notificationAppSessionStorage.getString(
notificationAppSessionStorage.getIncomingKeyValueStorage(),
""
)
if (id != "") {
updateNotificationListItemUseCase.build(id.toInt(), true, false, false)
}
}
}
我的主张:
我已阅读文档https://developer.android.com/kotlin/coroutines/coroutines-best-practices
val IODispatcher: CoroutineDispatcher = Dispatchers.IO
val externalScope: CoroutineScope = CoroutineScope(IODispatcher)
suspend {
externalScope.launch(IODispatcher) {
vm.getIdWithUpdate()
}.join()
}
第二个选项,但这里我不等到工作完成
suspend {
withContext(Dispatchers.IO) {
vm.getIdWithUpdate()
}
}
你怎么看? 不是提供给ANR吗,我也阻塞线程了。
您可以在 MainActivity
中使用 lifecycleScope
而不是 GlobalScope
来启动协程:
lifecycleScope.launch {
vm.getIdWithUpdate() // calling suspend function
// here suspend function `vm.getIdWithUpdate()` finished execution
// ... do something after suspend function is done
}
要使用lifecycleScope
添加依赖:
implementation 'androidx.lifecycle:lifecycle-runtime-ktx:.4.0'
强烈建议不要使用 GlobalScope
。而且不需要调用job.join()
,你可以在调用vm.getIdWithUpdate()
之后在coroutine builder block中做一些事情,比如更新UI。此协程是 运行 使用 Dispatchers.Main
上下文。