scala - 同步 2 个或更多 Future 的计算

Question

我发现我无法弄清楚如何同步 2 和更多的计算 Futures :

val fs = List(1, 2, 3) map { x => Future { /* some computation depending on x... */ } }
fs(0) onComplete {
  case Success(x) => 
    fs(1) onComplete { 
      case Success(x) => 
        fs(2) onComplete ....
}

这看起来不太明智。

我想从 fs 中获取所有值.我该怎么做呢？

Answer 1

使用 Future.traverse

val inList = List(1, 2, 3)
val fs = Future.traverse(inList) { x =>
  Future {
    /* some computation depending on x... */
  }
}

fs onSuccess { case outList => 
  ...
}

如果任何元素失败，这将失败。

如果你想要所有的结果，不管失败还是成功，那么最好的方法就是 recover它们，将结果包装在 Try 的实例中:

def asyncFunc(i: Int): Future[String] = ...

val inList = List(1, 2, 3)
val rawResults = inList.map(asyncFunc)
val recoveredResults = rawResults.map(Success(_)).recover(case x => Failure(x))

val completedResults = Future.sequence(recoveredResults)

completedResults onSuccess { case outList =>
  outList map {
    case Success(s) => ...
    case Failure(t) => ...
  }
}

提示:如果你经常做这种事情，通常更容易确保 全部 您的异步方法使用 Future[Try[T]] 的实例成功完成，而不是在 Future 中嵌入任何错误

像这样的东西:

def slowFunc(i: Int): String = ...
def asyncFunc(i: Int): Future[Try[String]] = Future { Try { slowFunc(i) } }

val inList = List(1, 2, 3)
val results = Future.traverse(inList)(asyncFunc)

results onSuccess { case outList =>
  outList map {
    case Success(s) => ...
    case Failure(t) => ...
  }
}