scala - 计算 future 列表并返回结果 future

Question

我有一个接收 future 的函数 Future[A]*我希望它返回一个 Future[List[A]] .

def singleFuture[T](futures: List[Future[A]]): Future[List[A]] = {
  val p = Promise[T]
  futures filter { _ onComplete { case x => p complete x /*????*/ } }
  p.future
} 

而且我还想要类型 Future[List[A]] 的结果 future 挂牌 future 后立即完成 List[Future[A]]已经完成。

该代码不起作用。我想我应该使用 flatMap因为应该有 2 个内部循环:一个用于 future ，一个用于 promise 。但是如何？

我不想用 为 在这里理解是因为我想了解更深层次的过程。

Answer 1

这已经为您实现了:

def singleFuture[T](futures: List[Future[A]]): Future[List[A]] = Future.sequence(futures)

当然，你可以看看sequence的实现:

def sequence[A, M[_] <: TraversableOnce[_]](in: M[Future[A]])(implicit cbf: CanBuildFrom[M[Future[A]], A, M[A]], executor: ExecutionContext): Future[M[A]] = {
  in.foldLeft(Promise.successful(cbf(in)).future) {
    (fr, fa) => for (r <- fr; a <- fa.asInstanceOf[Future[A]]) yield (r += a)
  } map (_.result())
}

如果你只想处理列表，而不是任何有 foldLeft 的东西，这可以简化:

def sequence[A](in: List[Future[A]]): Future[List[A]] = {
  in.foldRight[Future[List[A]](Promise.successful(Nil) {
    (fa, fr) => for { r <- fr; a <- fa } yield (a :: r)
  }
}