Java中CompletableFuture异常处理：如何实现列表迭代出错不中断继续执行

核心逻辑是将异常捕获的粒度从整个异步任务层级下沉到单个元素的处理层级，避免单元素异常中断整个遍历流程，具体实现可参考以下两种方案：

方案1：在遍历逻辑中单独捕获单元素异常 #

直接修改computations方法，在每次调用otherFunction时包裹try-catch逻辑，单个元素抛出的异常只会被当场捕获处理，不会向上抛出中断遍历：

public void computations() {
  // 原代码stream.forEach的lambda参数有误，已修正为接收遍历元素的写法
  list.forEach(item -> {
    try {
      otherFunction();
    } catch (Exception e) {
      // 可按需打印当前处理的元素信息，方便排查问题
      log.info("处理元素{}时发生异常: {}", item, e.getMessage(), e);
    }
  });
}

原有someFunction的exceptionally可以保留，用于捕获遍历过程之外的其他未知异常，避免整个异步任务抛出未捕获异常影响应用运行。

方案2：直接在被调用方法内部做异常兜底 #

如果otherFunction在所有调用场景下都不希望向外抛出异常，可以直接在方法内部做异常捕获：

public void otherFunction() {
  try {
    // 原有可能抛出异常的业务计算逻辑
  } catch (Exception e) {
    log.info("执行otherFunction时发生异常: {}", e.getMessage(), e);
  }
}

这种方案无需修改遍历逻辑，所有调用otherFunction的场景都不会因为方法执行异常中断上层逻辑。

可选进阶方案：并行处理列表元素时的异常隔离 #

如果需要并行处理列表中的元素，同时保证单元素异常不影响其他任务执行，可以将每个元素的处理封装为独立的CompletableFuture：

public void someFunction () {
  // 每个元素对应一个独立的异步任务，各自处理自身异常
  List<CompletableFuture<Void>> taskFutures = list.stream()
    .map(item -> CompletableFuture.runAsync(() -> otherFunction())
      .exceptionally(err -> {
        log.info("处理元素{}时发生异常: {}", item, err.getMessage(), err);
        return null;
      }))
    .toList();
  // 等待所有任务全部执行完成，不会因为单个任务异常提前终止
  CompletableFuture.allOf(taskFutures.toArray(new CompletableFuture[0])).join();
}

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