微服务场景下如何正确合并两个CompletableFuture的执行结果？

问题根源 #

• @Async方法未真正异步执行：当前getDashboardItemsFuture1/2方法中，executeRestCall()是同步执行后再用CompletableFuture.completedFuture()包装，导致REST调用在调用方线程立即执行，异常直接抛出，无法被异步线程池或CompletableFuture处理。
• 单个Future异常未隔离处理：原代码中调用单个Future的get()方法时，若该Future包含异常会直接抛出，导致无法收集另一个Future的正常结果。

修正方案 #

1. 修复@Async方法的异步逻辑 #

要让REST调用真正在指定线程池异步执行，需将调用逻辑放入CompletableFuture.supplyAsync()中，确保执行和异常都被包裹在Future内部：

@Async("executor")
public CompletableFuture<List<DashboardItem>> getDashboardItemsFuture1() {
    return CompletableFuture.supplyAsync(this::executeRestCall, executor);
}

@Async("executor")
public CompletableFuture<List<DashboardItem>> getDashboardItemsFuture2() {
    return CompletableFuture.supplyAsync(this::executeRestCall, executor);
}

注：这里的executor需对应@Async注解中指定的线程池实例，确保异步任务在目标线程池执行。

2. 安全的结果合并逻辑 #

通过等待所有任务完成，再单独处理每个Future的结果或异常，确保一个调用失败时不影响另一个结果的收集：

List<DashboardItem> dashboardItems = new ArrayList<>();

// 发起两个异步调用
var future1 = getDashboardItemsFuture1();
var future2 = getDashboardItemsFuture2();

// 等待所有异步任务完成（无论成功或失败）
CompletableFuture.allOf(future1, future2).join();

// 分别处理每个Future的结果
processFuture(future1, dashboardItems);
processFuture(future2, dashboardItems);

return dashboardItems;

// 辅助处理方法
private void processFuture(CompletableFuture<List<DashboardItem>> future, List<DashboardItem> resultList) {
    try {
        List<DashboardItem> items = future.get();
        Optional.ofNullable(items).ifPresent(resultList::addAll);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        log.error("异步任务线程被中断", e);
    } catch (ExecutionException e) {
        log.error("异步调用失败", e.getCause());
        // 可在此添加降级逻辑，比如添加默认数据或空列表
    }
}

核心要点 #

• 使用CompletableFuture.allOf(...).join()替代get()，简化等待逻辑且无需处理受检异常。
• 对每个Future单独捕获异常，实现异常隔离，保证一个任务失败时另一个的正常结果仍能被收集。
• 修正后的@Async方法真正实现异步执行，异常会被CompletableFuture包裹，不会在调用方线程直接抛出。

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