如何将Seq[Future[Object]]转为Future[Seq[Object]]？无需Await的优雅实现

当然可以！你当前用Await.result的方式会阻塞线程，完全浪费了Future异步处理的优势，我们可以用Scala标准库提供的Future.sequence来优雅地解决这个问题，全程保持非阻塞。

核心思路 #

Future.sequence的作用就是把Seq[Future[T]]转换为Future[Seq[T]]——它会异步等待所有Future完成，然后把结果收集成一个序列，整个过程不需要任何阻塞操作。之后我们只需要在这个Future上调用map，对内部的序列执行forall检查即可。

代码示例 #

假设你的Object[Boolean]是一个持有Boolean属性的包装类（比如命名为BoolHolder），代码可以写成这样：

import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global

// 模拟你的持有Boolean属性的类
case class BoolHolder(isValid: Boolean)

// 你的原始Future序列
val futureObjects: Seq[Future[BoolHolder]] = Seq(
  Future.successful(BoolHolder(true)),
  Future.successful(BoolHolder(true)),
  Future.successful(BoolHolder(false)) // 示例中的一个失败项
)

// 转换为Future[Seq[BoolHolder]]并执行forall检查
val allValid: Future[Boolean] = Future.sequence(futureObjects).map { objSeq =>
  objSeq.forall(_.isValid)
}

关键说明 #

1. 非阻塞特性：整个过程完全异步，不会阻塞当前线程，所有Future的处理都在ExecutionContext管理的线程池中进行。
2. 失败处理：如果序列中有任何一个Future失败，Future.sequence会直接返回失败的Future。如果需要处理这种情况，可以用recover或recoverWith来捕获异常：

   val allValidWithRecovery: Future[Boolean] = Future.sequence(futureObjects)
     .map(_.forall(_.isValid))
     .recover { case _: Exception => false } // 发生异常时默认返回false
   

3. 后续处理：得到的allValid是一个Future[Boolean]，你可以继续用map/flatMap链式处理结果，或者在合适的异步场景（比如Play框架的Action、Akka的Actor消息处理）中直接使用，完全不需要Await。

和你当前实现的对比 #

你原来的代码会逐个阻塞等待每个Future完成，不仅性能差（无法并行处理Future），还可能导致线程池耗尽的问题。而用Future.sequence的方式可以并行处理所有Future，充分利用异步优势，代码也更简洁符合Scala的函数式风格。

内容的提问来源于stack exchange，提问作者SomeStranger314