在 completionstage.copy() 中使用函数式接口，核心在于理解该方法返回的是一个新的 completionstage 实例，其状态与原阶段完全同步。你不需要手动传递函数式接口给 copy() 本身，而是通过链式调用 thenapply、thenaccept 等方法来注入你的逻辑。这些方法接受 function、consumer 等函数式接口作为参数，从而实现对复制后阶段的处理。
如何创建并验证 CompletionStage 的副本
要创建一个 CompletionStage 的副本，直接调用原阶段的 copy() 方法即可。这个方法会立即返回一个新的 CompletionStage，该副本与原阶段共享同一个完成状态。如果原阶段已经完成，副本也会立即完成；如果原阶段尚未完成，副本将等待原阶段完成后自动完成。这种机制允许你在不阻塞主线程的情况下，为后续操作准备一个独立的引用。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
public class CopyDemo {
public static void main(String[] args) {
// 创建一个原始的 CompletionStage
CompletionStage<string> original = CompletableFuture.supplyAsync(() -> "Hello");
// 使用 copy() 方法创建副本
CompletionStage<string> copy = original.copy();
// 验证副本是否与原阶段同步
copy.thenAccept(result -> System.out.println("Copy result: " + result));
original.thenAccept(result -> System.out.println("Original result: " + result));
}
}</string></string>
运行上述代码，你会看到控制台输出两次 "Hello"，分别来自 original 和 copy 的处理逻辑。这证明了 copy() 确实创建了一个与原阶段状态同步的新实例。你可以对 copy 进行独立的链式调用，而不会影响 original 的状态，除非它们都依赖于同一个底层异步任务。
如何在副本上应用不同的函数式接口
一旦获得了 CompletionStage 的副本，你就可以像处理普通阶段一样，在其上应用各种函数式接口。例如，使用 thenApply 来处理返回值，使用 thenAccept 来消费结果，或者使用 exceptionally 来处理异常。关键在于，每个方法都会返回一个新的 CompletionStage，形成一条处理链。你可以在副本上构建一条与原始阶段完全不同的处理路径，从而实现逻辑的分离。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
public class CopyWithFunctions {
public static void main(String[] args) {
CompletionStage<integer> original = CompletableFuture.supplyAsync(() -> 42);
// 创建副本
CompletionStage<integer> copy = original.copy();
// 在副本上应用不同的函数式接口
copy.thenApply(n -> n * 2)
.thenAccept(doubled -> System.out.println("Doubled: " + doubled))
.exceptionally(ex -> { ex.printStackTrace(); return null; });
// 原始阶段可以有不同的处理逻辑
original.thenAccept(n -> System.out.println("Original: " + n));
}
}</integer></integer>
在这个例子中，copy 阶段被赋予了乘以 2 的逻辑，而 original 阶段则直接打印结果。由于 copy() 创建的副本与原阶段同步，当 original 完成时，copy 也会完成，进而触发 copy 上的 thenApply 和 thenAccept 链。这展示了如何利用 copy() 来并行处理同一数据的不同逻辑分支。
当原阶段抛出异常时，副本的行为是什么
如果原始的 CompletionStage 在执行过程中抛出了异常，那么它的副本也会以相同的方式完成，即处于异常完成状态。这意味着，如果你在副本上注册了 exceptionally 处理器，它将会被触发，并且接收到的异常与原始阶段抛出的异常完全相同。这种行为确保了异常处理的透明性，无论你是否使用了 copy()，异常都会沿着依赖链传播。因此，在处理可能失败的异步任务时，建议在副本上也配置适当的异常处理逻辑，以避免未捕获的异常导致程序崩溃。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
