如何关联两个CompletableFuture实现完成状态完全同步？

解决方案 #

方案1：Java 12+ 最简写法 #

Java 12 为CompletableFuture新增了内置的completeWith方法，完全匹配你的需求：直接将目标Future的完成状态和源Future绑定，源成功则目标返回相同结果，源异常则目标抛出相同异常，一行代码即可实现：

public void m(CompletableFuture f) {
    f.completeWith(executeOperation());
}

方案2：Java 8~11 兼容写法 #

如果你使用的Java版本低于12，没有内置的completeWith方法，你现有基于whenComplete的写法已经是原生API下最简洁的实现了。如果有多处相同逻辑需要复用，可以把转发逻辑封装为通用工具方法：

// 通用工具方法
public static <T> void forwardFutureResult(CompletableFuture<T> target, CompletionStage<T> source) {
    source.whenComplete((result, throwable) -> {
        if (throwable != null) {
            target.completeExceptionally(throwable);
        } else {
            target.complete(result);
        }
    });
}

// 业务代码调用
public void m(CompletableFuture f) {
    forwardFutureResult(f, executeOperation());
}

注意事项 #

• 上述所有实现的默认行为都是：如果入参f已经被提前完成，那么后续的结果转发会自动失效，不会覆盖已有的完成状态。如果你的场景需要强制覆盖已有结果，可以把complete替换为obtrudeValue，completeExceptionally替换为obtrudeException。
• 示例代码中的CompletableFuture没有携带泛型，实际生产使用建议补充泛型约束，避免类型转换风险。

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