如何在 MainActivity 中等待直到完成来管理协程?

How to manage coroutines in MainActivity with waiting until done?

我在 MainActivity 中使用 GlobalScoperunBlocking,但我不使用流只是暂停功能。我想将 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 上下文。