时间戳

首页 > 解决方案 > 在 Kotlin 中以同步方式运行异步任务

firebase - 在 Kotlin 中以同步方式运行异步任务

问题描述

我正在尝试运行 Firebase Firestore 的“批量”作业。由于批处理作业是异步的，并且每个批处理只处理 500 个文档，所以我创建了一个批处理作业数组，我想以同步方式运行，这样我就可以准确地知道最后一个批处理何时完成，然后继续下一个手术。

但是，要在 Kotlin 中执行此操作，当我阅读时，我遇到了许多行话，例如 runBlocking、Coroutine、Dispatcher、async、await、Context、Suspend、launch、join、Scope、Deferred、Continuation、CommonPool

此外，许多帖子说在最新版本的 Kotlin 中情况发生了变化。Kotlin文档谈到了 runBlocking，但这篇文章说 runBlocking 是坏事。

经过一些试验和错误后，我得到了编译

suspend fun doTheThing() {

   for ( b in batchArray) {
      coroutineScope {
      val job = async { b.commit() }
      job.await()
  }}
}

但是，现在我收到错误消息“暂停函数'doTheThing'应该只从协程或另一个暂停函数中调用”我现在很困惑。我只想按顺序进行这些调用，或者等到所有这些都完成。不确定完成此操作的正确语法是什么，以及我弄错了哪些概念。

更新：以下代码片段似乎正在工作：

for ( b in batchArray) {
    runBlocking {b.commit()}
}

这样做是一个好习惯吗？

标签： firebasekotlingoogle-cloud-firestorekotlin-coroutines

解决方案

协程通常由不同的构建器在某个协程范围的上下文中创建。与构建器一样，挂起函数在协程范围内运行，因此应该在协程范围内调用，这可以通过在协程、挂起函数内调用或从定义的范围内显式调用来提供。

CoroutineScope 是一个接口，它只包含一个属性，即coroutineContext。您可以通过实现 CoroutineScope 接口来简单地创建自己的范围并覆盖您自己的协程上下文。

val myCoroutineScope = object : CoroutineScope {
    override val coroutineContext: CoroutineContext
        get() = Job() + Dispatchers.Main
}

在您的范围内，您可以使用启动、异步、生产等构建器。

您可以将您的功能重构为

suspend fun doTheThing() = coroutineScope{
for ( b in batchArray) {
    b.commit()
   }
}

fun main(args: Array<String>) {
    myCoroutineScope.launch {
        doTheThing()
        println("Completed")   
      }
}

我在这里使用了启动，因为我们并不真正关心结果。挂起函数将挂起父协程作用域，直到它完成执行。

您还可以选择在另一个调度程序中运行您的范围

fun main(args: Array<String>) {

myCoroutineScope.launch(Dispatchers.IO) {
    doTheThing()
    println("Completed")
   }
}

为了获得更好的结果，我们不希望取消任何子协程来取消范围，我们使用 SuperVisor Job 代替常规 Job。

val myCoroutineScope = object : CoroutineScope {
override val coroutineContext: CoroutineContext
    get() = SupervisorJob() + Dispatchers.Default
}

推荐阅读