如何判断Java中Completable Future是否执行出错？

当使用CompletableFuture.allOf()时，join()只会抛出第一个遇到的异常，无法直接定位是哪个异步任务失败。可以通过以下两种方式解决：

方法一：逐个检查每个CompletableFuture的状态 #

在allOf().join()之后（或捕获全局异常后），分别调用每个Future的isCompletedExceptionally()判断是否失败，再通过join()获取具体异常信息：

CompletableFuture<ProductResponse> productFuture = CompletableFuture.supplyAsync(() ->
        productAPI(productRequest)
);
CompletableFuture<VendorResponse> vendorFuture= CompletableFuture.supplyAsync(() ->
        vendorAPI.postLogin(vendorRequest)
);

try {
    CompletableFuture.allOf(productFuture, vendorFuture).join();
    
    // 逐一验证任务状态
    if (productFuture.isCompletedExceptionally()) {
        try {
            productFuture.join(); // 触发具体异常
        } catch (Exception e) {
            System.err.println("Product API任务失败: " + e.getMessage());
        }
    }
    if (vendorFuture.isCompletedExceptionally()) {
        try {
            vendorFuture.join();
        } catch (Exception e) {
            System.err.println("Vendor API任务失败: " + e.getMessage());
        }
    }
} catch (Exception e) {
    // 捕获到全局异常后，仍需逐个排查具体失败任务
    System.err.println("至少一个任务失败，开始定位具体任务:");
    
    if (productFuture.isCompletedExceptionally()) {
        try {
            productFuture.join();
        } catch (Exception pe) {
            System.err.println("Product API失败原因: " + pe.getMessage());
        }
    }
    if (vendorFuture.isCompletedExceptionally()) {
        try {
            vendorFuture.join();
        } catch (Exception ve) {
            System.err.println("Vendor API失败原因: " + ve.getMessage());
        }
    }
}

方法二：提前给每个Future绑定异常处理逻辑 #

在创建Future时，用whenComplete()附加异常回调，实时记录当前任务的错误信息，无需等到全局allOf执行完成再排查：

// 用于存储任务错误信息的容器（线程安全）
Map<String, Exception> errorMap = new ConcurrentHashMap<>();

CompletableFuture<ProductResponse> productFuture = CompletableFuture.supplyAsync(() ->
        productAPI(productRequest)
).whenComplete((response, ex) -> {
    if (ex != null) {
        errorMap.put("Product API", ex);
    }
});

CompletableFuture<VendorResponse> vendorFuture= CompletableFuture.supplyAsync(() ->
        vendorAPI.postLogin(vendorRequest)
).whenComplete((response, ex) -> {
    if (ex != null) {
        errorMap.put("Vendor API", ex);
    }
});

try {
    CompletableFuture.allOf(productFuture, vendorFuture).join();
} catch (Exception e) {
    // 可选：处理全局异常提示
}

// 输出所有失败任务的信息
if (!errorMap.isEmpty()) {
    errorMap.forEach((taskName, ex) -> {
        System.err.println(taskName + "执行失败，原因: " + ex.getMessage());
    });
}

核心方法说明 #

• isCompletedExceptionally()：返回true即表示该Future已因异常终止
• whenComplete(BiConsumer)：任务完成（成功/失败）时触发，通过第二个参数获取异常对象
• join()：在确认任务失败后调用，会抛出任务执行时的具体异常

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