计算期货清单并返回结果未来

Question

我有一个功能,需要期货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]]在列表期货完成后立即List[Future[A]]完成.

该代码不起作用.我想我应该flatMap在这里使用,因为应该有2个内部循环:一个用于未来,一个用于promise.但是怎么样？

我想不能用的理解,因为我想了解的过程中,在更深一层意义上这里.

Answer 1

这已经为您实现:

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

当然,您可以查看序列的实现:

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)
  }
}