Scala基于Future[Try[Int]]实现Either嵌套过滤的类型不匹配问题求解

云上老周

2026-10-12

问题原因

你已经定位到了核心问题：List.filter 要求传入的函数返回同步的Boolean值，但你的过滤逻辑依赖异步返回的Future，所以直接在filter块里返回Future会触发类型不匹配。

解决方案

核心思路是先异步计算所有记录的过滤标记，再基于完成后的异步结果做同步过滤，步骤如下：

把每一条记录映射为「(是否保留标记, 记录本身)」的Future
用Future.sequence把整个List的Future聚合成一个包含所有结果的Future
等聚合Future完成后，过滤出标记为true的记录即可

示例代码

import scala.concurrent.Future
// 下面的全局 ExecutionContext 按需替换成你业务中自定义的线程池即可
import scala.concurrent.ExecutionContext.Implicits.global

val records: List[CommittableRecord[Either[Throwable, MyEvent]]] = ???

val futureFilteredRecords: Future[List[CommittableRecord[Either[Throwable, MyEvent]]]] = Future.sequence(
  records.map { record =>
    record.value match {
      case Right(event) =>
        // 这里替换了原来的不安全调用.get，避免键不存在时抛出空指针
        event.get("task") match {
          case Some(taskId) =>
            getTaskId(taskId).map { tryInt =>
              tryInt match {
                case Success(value) => value > 1
                case Failure(_) => false
              }
            }.map(keep => (keep, record))
          case None =>
            Future.successful((false, record))
        }
      case Left(_) =>
        Future.successful((false, record))
    }
  }
).map { resultList =>
  // 所有异步判断完成后，同步过滤出符合要求的记录
  resultList.collect { case (true, record) => record }
}