Scala 等待异步调用在循环中完成

Question

我是 scala 的新手，我必须在遍历 for each 循环时进行异步调用(使用 elastic4s 进行弹性索引)。在 Scala 中执行此操作的最佳方法是什么。

val data = List("1","2","3","4")

data.foreach(element=>{
          asyncCall(element)
        })

如何在所有 asyncCall 完成后执行一些操作。我不想对响应做任何事情。如果一切成功就打印成功，如果任何调用失败就打印失败。 asyncCall 返回 Future[T]。

Answer 1

您应该使用 Future.sequence。它将 List[Future[T]] 更改为 Future[List[T]]。

所以在你的例子中:

import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{Failure, Success}

val f = Future.sequence(data.map(asyncCall)) // Future[List[String]] 

//you can now do something when future finishes:
f.onComplete{
  case Success(s) => println(s"Evethings fine: $s")
  case Failure(e) => println(s"Something went wrong: $e")
}