计算期货的列表并返回结果的未来
计算期货的列表并返回结果的未来
提问于 2013-11-29 03:56:29
我有一个函数，它接受期货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
Stack Overflow用户
回答已采纳
发布于 2013-11-29 06:57:28
您可以使用foldRight来实现这一点：
def singleFuture[A](futures: List[Future[A]]): Future[List[A]] = {
val p = Promise[List[A]]()
p.success(List.empty[A])
val f = p.future // a future containing empty list.
futures.foldRight(f) {
(fut, accum) => // foldRight means accumulator is on right.
for {
list <- accum; // take List[A] out of Future[List[A]]
a <- fut // take A out of Future[A]
}
yield (a :: list) // A :: List[A]
}
}如果期货列表中的任何未来失败，<- fut将失败，从而导致accum被设置为失败的未来。
如果要避免使用for，可以将其展开为flatMap，如下所示：
accum.flatMap( list => fut.map(a => a :: list))或者您可以使用异步等待(注意它仍然是一个实验性的特性)。
def singleFuture[T](futures: List[Future[T]]): Future[List[T]] = async {
var localFutures = futures
val result = ListBuffer[T]()
while (localFutures != Nil) {
result += await { localFutures.head }
localFutures = localFutures.tail
}
result.toList
}Stack Overflow用户
发布于 2013-11-29 04:57:33
这已经为您实现了：
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)
}
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/20278133
复制相关文章
相似问题
腾讯云开发者
