如何简化主备并行CompletableFuture的容错处理代码？

你的需求是并行启动主、备两个进程，主进程优先，失败则 fallback 到备份进程，这段代码确实可以通过CompletableFuture的原生API简化，无需手动创建并管理额外的resultFut：

兼容Java 8的简化写法 #

final CompletableFuture<Data> mainFut = mainProcess(...);
final CompletableFuture<Data> backupFut = backupProcess(...);

return mainFut.handle((result, throwable) -> {
    if (throwable == null) {
        // 主进程成功，直接返回已完成的Future
        return CompletableFuture.completedFuture(result);
    } else {
        LOGGER.error("主进程执行失败，将使用备份进程结果", throwable);
        // 主进程失败，返回备份进程的Future
        return backupFut;
    }
})
// 展开嵌套的CompletableFuture，将内层结果传递出来
.thenCompose(Function.identity())
// 处理备份进程也失败的情况，可根据需求调整异常处理逻辑
.exceptionally(throwable -> {
    throw new RuntimeException("主进程与备份进程均执行失败", throwable);
});

Java 9+ 更简洁的写法 #

Java 9新增了exceptionallyCompose方法，可以直接在主进程失败时链式调用备份进程，代码更紧凑：

final CompletableFuture<Data> mainFut = mainProcess(...);
final CompletableFuture<Data> backupFut = backupProcess(...);

return mainFut.exceptionallyCompose(throwable -> {
    LOGGER.error("主进程执行失败，将使用备份进程结果", throwable);
    return backupFut;
});

简化说明 #

1. 去掉了手动创建的resultFut，利用CompletableFuture的链式调用自动管理结果流转，避免手动调用complete/completeExceptionally的冗余代码
2. 主进程成功时直接返回已完成的Future，失败则无缝切换到备份进程的Future
3. Java 9+的exceptionallyCompose专门用于这种"失败后切换到另一个异步任务"的场景，完美匹配你的需求

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