CompletableFuture 简介
CompletableFuture 是 Java 并发 API 的一部分，代表了异步计算的结果，并且可以对其进行操作和组合。与 Future 接口相比，CompletableFuture 提供了更多的灵活性和控制能力，允许开发者以声明式的方式构建复杂的异步逻辑。
基本用法
创建 CompletableFuture
创建 CompletableFuture 实例有多种方式：
使用 supplyAsync 来异步执行一个供应者函数。
使用 runAsync 来异步执行一个 Runnable 任务。
使用 completedFuture 来立即完成一个 Future。
java">CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 模拟长时间运行的任务timeConsumingTask();return "Result";
});
处理结果
使用 thenApply、thenAccept 或 thenRun 来处理异步操作的结果：
java">future.thenAccept(result -> {System.out.println("Processing result: " + result);
});
异常处理
CompletableFuture 提供了 exceptionally 方法来处理可能发生的异常：
java">future.exceptionally(throwable -> {System.err.println("Error occurred: " + throwable.getMessage());return null;
});
组合 CompletableFuture
CompletableFuture 的强大之处在于它可以与其他 CompletableFuture 实例组合，创建更复杂的异步逻辑。
组合多个 CompletableFuture
使用 allOf 或 anyOf 来等待多个 CompletableFuture 实例完成：
java">CompletableFuture<Void> allDone = CompletableFuture.allOf(future1, future2, future3);
链式调用
使用 thenCompose 来创建一个基于前一个 CompletableFuture 结果的新 CompletableFuture：
java">future.thenCompose(result -> {return new CompletableFuture<>()...; // 根据结果创建新的任务
});
并行执行
使用 runAsync 并行执行多个任务，然后使用 thenAcceptBoth 等方法来处理它们的结果：
java">CompletableFuture<String> futureA = CompletableFuture.supplyAsync(() -> "A");
CompletableFuture<Integer> futureB = CompletableFuture.supplyAsync(() -> 1);futureA.thenAcceptBoth(futureB, (a, b) -> {System.out.println("Result from A: " + a + ", Result from B: " + b);
});
优势与最佳实践
非阻塞：CompletableFuture 提供了一种非阻塞的方式来处理异步操作。
易于组合：可以轻松地将多个异步操作组合成复杂的逻辑。
错误处理：提供了更好的错误处理机制。
API 丰富：提供了大量方法来处理各种异步场景。
最佳实践
使用 supplyAsync 来异步执行计算密集型任务。
使用 runAsync 来异步执行 I/O 密集型任务。
总是考虑异常处理，使用 exceptionally 来优雅地处理错误。
避免在 CompletableFuture 的链中同步阻塞，这会丧失异步的优势。
结论
CompletableFuture 是 Java 并发编程中一个非常有用的工具，它提供了一种简洁、强大的方式来编写异步、非阻塞的代码。通过本文的介绍，你应该能够理解 CompletableFuture 的基本概念，并开始在项目中使用它来简化多线程编程。记住，合理使用 CompletableFuture 可以显著提高应用程序的性能和响应能力。
