Scala：当一些期货超时时，如何收集期货列表的结果？

Question

在这种情况下，我的做法是使用 .sequence 将 F[G[A]] 转换为 G[F[A]]。然后使用 Await.result（future_of_a_list，time_out）获取结果。但是，可能有一个任务需要很长时间并且超时。在这种情况下，我仍然希望获得其余结果（同时并行运行所有任务）。可能吗？怎么办？

谢谢

Answer 1

我同意@Kolmar的想法。他的解决方案中的变换（）是新的Scala 2.12. x版本，而在2.11. x中它有不同的签名。我试图升级，但遇到了依赖问题。我找到了使用2.11. x的回退到的方法。由于我的Await.result（f，1秒））将返回一个scalaz.Validation[Throwable， T]，它也是这样工作的：

val fs = Future.traverse(s)(f => 
     Future(Await.result(f, 1 second)).fallbackTo(Future(Failure(new TimeoutException())))

Answer 2

好的，您可以将每个＜code＞等待＜/code＞包装在另一个＜code＞未来＜/code＞中：

import scala.concurrent.{Await, Future}
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duration._
import scala.util.Success

scala> val s = Seq(Future(1), Future(2), Future { Thread.sleep(2000); 3 })
s: Seq[scala.concurrent.Future[Int]] = List(Future(Success(1)), Future(Success(2)), Future(<not completed>))

scala> val fs = Future.traverse(s)(f => 
         Future(Await.result(f, 1 second)).transform(Success(_)))
fs: scala.concurrent.Future[Seq[scala.util.Try[Int]]] = Future(<not completed>)

scala> Await.result(fs, Duration.Inf)
res2: Seq[scala.util.Try[Int]] = List(Success(1), Success(2), Failure(java.util.concurrent.TimeoutException: Futures timed out after [1 second]))