如何处理CompletableFuture可能为空或触发NullPointerException的场景？

一、解决createFutureA中的NullPointerException问题 #

异步任务中抛出的NPE会让futureA进入异常完成状态，调用get()时会触发ExecutionException。我们可以通过前置参数校验和异常捕获提前处理：

private CompletableFuture<PPPInfo> createFutureA(
      MultipleItems multipleItems,
      String startDate,
      Source source,
      Context context) {
    // 提前校验ItemA及价格是否为空
    ItemA itemA = multiplePrices.getItemA();
    if (itemA == null || itemA.getPrice() == null) {
        // 方案1：返回默认值的已完成Future
        return CompletableFuture.completedFuture(null); 
        // 方案2：返回异常标记的Future（后续可捕获处理）
        // return CompletableFuture.failedFuture(new IllegalArgumentException("ItemA或价格为空"));
    }

    // 处理价格解析异常
    try {
        double price = Double.parseDouble(itemA.getPrice());
        return CompletableFuture.supplyAsync(
            () -> getItemAPrice(price, startDate, source, ITEMA, context));
    } catch (NumberFormatException e) {
        return CompletableFuture.failedFuture(e);
    }
}

二、处理futureA本身为空的情况 #

如果createFutureA存在返回null的可能，在赋值时必须兜底，否则CompletableFuture.allOf()会直接抛出NPE：

// 确保futureA永远是非空的CompletableFuture实例
CompletableFuture<Info> futureA = Optional.ofNullable(
        createFutureA(multipleItems, startDate, source, context)
    )
    .orElseGet(() -> CompletableFuture.completedFuture(null)); // 或返回异常Future

CompletableFuture<PPPInfo> futureB = createFutureB(multipleItems, startDate, source, context);
CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(futureA, futureB);

三、结果处理时的异常兼容 #

避免直接调用get()阻塞线程，推荐用非阻塞方式处理结果，或捕获异常：

// 非阻塞处理结果
combinedFuture.whenComplete((v, throwable) -> {
    if (throwable != null) {
        // 处理整体执行异常
        System.err.println("任务执行失败：" + throwable.getMessage());
        return;
    }

    try {
        Info info = futureA.join(); // join()不抛出受检异常，更简洁
        PPPInfo pppInfo = futureB.join();
        // 正常处理业务逻辑
    } catch (CompletionException e) {
        // 处理单个Future的异常
        System.err.println("单个任务失败：" + e.getCause().getMessage());
    }
});

核心要点总结 #

• 前置校验优先：在异步任务启动前完成参数合法性检查，避免异步线程中抛出未捕获异常
• 保证Future非空：所有返回CompletableFuture的方法，必须返回非空实例（哪怕是异常完成或默认值的Future）
• 显式异常处理：通过completedFuture、failedFuture主动标记异常状态，便于后续统一处理

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