CompletableFuture异常时可控中止链式执行：选项A是否正确？选项B能否实现？

选项A是不是正确的中止方式？ #

肯定不是。核心问题出在isCompletedExceptionally()是同步检查方法，而CompletableFuture是异步执行的：

• 当你调用这个方法时，stage1可能还在后台异步执行，此时检查结果会是false，程序会继续绑定stage2；
• 等后续stage1真的抛出异常时，你的同步判断早就执行完毕，根本触发不了return SOME_DEFAULT_VALUE的逻辑；
• 这种同步检查完全适配不了异步场景，没法可靠捕获异步执行的异常，逻辑从根上就不成立。

选项B能不能实现中止执行并返回默认值？ #

可以，但需要调整链式调用的结构：
首先纠正一个错误——exceptionally的回调函数接收Throwable参数，返回的是具体的T类型值，不是CompletableFuture<T>，你代码里的注释描述有误。

要让stage2在stage1出错时完全不执行，最直接且优雅的写法是把exceptionally放在整个链式调用的最后：

processedFuture = someCompletableFuture
    .thenApply(<stage1>)
    .thenApply(<stage2>)
    .exceptionally(ex -> {
        log.error("stage1执行出错", ex);
        return SOME_DEFAULT_VALUE;
    });

原理说明： #

• 如果stage1正常执行，结果会传递给stage2处理，最终返回stage2的执行结果；
• 如果stage1抛出异常，后续的thenApply(<stage2>)会被自动跳过，异常直接传递到exceptionally阶段，此时直接返回SOME_DEFAULT_VALUE，完全中止了stage2的执行。

要是你必须把exceptionally放在stage1之后，也能实现需求，但逻辑会更啰嗦：在exceptionally里返回默认值，然后在stage2的回调中判断，若结果是默认值则直接返回，不做后续处理：

processedFuture = someCompletableFuture
    .thenApply(<stage1>)
    .exceptionally(ex -> {
        log.error("stage1执行出错", ex);
        return SOME_DEFAULT_VALUE;
    })
    .thenApply(result -> {
        if (result == SOME_DEFAULT_VALUE) {
            return result;
        }
        return <stage2>.apply(result);
    });

但显然第一种方式更简洁，利用CompletableFuture自带的异常传递特性，逻辑更清晰。

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