合并两个CompletableFuture遇异常时返回至少一个结果的实现方案

首先修正你初始代码中的变量名错误（两个Future都命名为future1）：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
    return "hello";
});
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
    return "world";
});

要实现任意一个Future失败时返回成功方的结果，全部成功则合并结果的需求，你不需要使用anyOf()（它只返回第一个完成的Future结果，无法兼顾两个Future的最终状态），正确的做法是给每个Future添加异常兜底处理，再合并判断结果：

完整实现代码 #

// 为每个Future添加异常处理，失败时返回null（也可根据需求返回其他标记值）
CompletableFuture<String> safeFuture1 = future1.exceptionally(ex -> {
    // 可选：记录future1的失败日志
    System.err.println("future1执行失败: " + ex.getMessage());
    return null;
});

CompletableFuture<String> safeFuture2 = future2.exceptionally(ex -> {
    // 可选：记录future2的失败日志
    System.err.println("future2执行失败: " + ex.getMessage());
    return null;
});

// 合并两个处理过异常的Future，根据结果动态返回
CompletableFuture<String> result = safeFuture1.thenCombine(safeFuture2, (s1, s2) -> {
    if (s1 == null && s2 == null) {
        // 两者均失败的场景，可抛出异常或返回默认值
        throw new RuntimeException("两个Future均执行失败");
    } else if (s1 == null) {
        return s2; // future1失败，返回future2的结果
    } else if (s2 == null) {
        return s1; // future2失败，返回future1的结果
    } else {
        return s1 + " " + s2; // 两者均成功，合并结果
    }
});

// 获取最终结果
System.out.println(result.join());

逻辑说明 #

1. 异常兜底：使用exceptionally()方法捕获每个Future的异常，返回null作为失败标记，确保两个Future都会进入完成状态（不会因为单个失败导致合并流程终止）。
2. 结果判断：在thenCombine()的回调中，根据两个结果是否为null来判断哪个Future失败，从而返回对应结果：
   • 两者都成功：拼接成hello world
   • 任意一个失败：返回成功方的结果
   • 两者都失败：抛出异常（或自定义默认返回值）
3. 失败排查：在exceptionally()中添加日志，可直接定位是哪个API调用失败，方便后续排查问题。

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