Scala：合并Future列表以捕获全部成功值并记录错误

首先要解决的核心问题是：原代码里的Future.foldLeft只要有单个Future失败，整个合并流程就会直接失败，无法保留其他已成功的结果。正确的思路是先让每个Future的结果都被捕获，再统一处理成功与失败的情况。

步骤1：将每个Future转为安全的Either类型 #

把每个Future[Seq[Element]]包装成Future[Either[Throwable, Seq[Element]]]，这样不管原Future成功还是失败，都会返回一个不会抛出异常的结果：

import scala.concurrent.Future
import scala.util.{Failure, Success}

val safeFutures: List[Future[Either[Throwable, Seq[Element]]]] = individualFutures.map { future =>
  future.transform {
    case Success(elements) => Right(elements)
    case Failure(err) => Left(err)
  }
}

步骤2：合并所有安全Future的结果 #

用Future.sequence把列表里的单个Future合并成一个包含所有结果的Future，这样就能一次性获取所有Future的执行状态：

val allResults: Future[List[Either[Throwable, Seq[Element]]]] = Future.sequence(safeFutures)

步骤3：处理结果，收集成功值并记录错误 #

异步处理合并后的Future，拆分成功元素和失败错误：

allResults.onComplete {
  case Success(results) =>
    // 收集所有成功返回的元素
    val successfulElements = results.collect {
      case Right(elements) => elements
    }.flatten.toList
    
    // 遍历所有失败记录并日志
    results.collect {
      case Left(err) => err
    }.foreach { err =>
      // 替换为你的实际日志逻辑
      println(s"Future执行失败: ${err.getMessage}")
    }
    
    // 后续处理成功收集到的元素
    handleSuccessfulElements(successfulElements)
    
  case Failure(err) =>
    // 此分支理论上不会触发，因为所有单个Future的失败已被捕获
    println(s"意外全局错误: ${err.getMessage}")
}

如果业务场景必须同步等待结果（不推荐在生产代码中使用Await，优先异步处理），可以改为：

import scala.concurrent.Await
import scala.concurrent.duration.Duration

val results = Await.result(allResults, Duration.Inf)
val successfulElements = results.collect { case Right(els) => els }.flatten.toList
results.collect { case Left(err) => err }.foreach(err => println(s"失败日志: ${err.getMessage}"))
// 处理成功元素逻辑...

原代码的问题说明 #

Future.foldLeft的执行逻辑是串行处理列表中的Future，一旦某个Future失败，整个合并Future会立即终止并抛出异常，既不会继续处理剩余Future，也无法保留之前已经成功的结果，完全不符合你“捕获所有可用值并记录错误”的需求。

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