CompletableFuture是Java中用于异步编程的核心工具，实现Future与CompletionStage接口，支持链式调用、任务组合及异常处理。通过supplyAsync和runAsync可创建有返回值或无返回值的异步任务，默认使用ForkJoinPool.commonPool()，也可指定自定义线程池。thenApply、thenAccept、thenRun实现结果转换与消费，thenCombine、thenCompose用于合并或串行依赖任务，allOf和anyOf协调多个任务的执行。异常处理通过exceptionally或handle方法完成，避免阻塞操作如get()，推荐回调方式提升I/O密集型场景下的性能与响应性。
在Java中，CompletableFuture 是处理异步编程的强大工具。它实现了 Future 和 CompletionStage 接口，支持链式调用、组合多个异步任务、异常处理以及回调机制，让非阻塞代码更清晰易读。
创建异步任务
你可以使用 runAsync 或 supplyAsync 启动一个异步操作：
- runAsync：执行无返回值的任务，适合 void 类型的操作。
- supplyAsync：执行有返回值的任务，返回 CompletableFuture<T>。
默认情况下，这些方法使用 ForkJoinPool.commonPool() 线程池，但也可以传入自定义线程池以更好控制资源。
示例：
立即学习“Java免费学习笔记（深入）”；
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
System.out.println("任务正在执行...");
});
CompletableFuture<String> supplyFuture = CompletableFuture.supplyAsync(() -> {
return "结果已生成";
});
链式调用与结果转换
通过 thenApply、thenAccept 和 thenRun 可以对前一个任务的结果进行后续处理：
- thenApply(Function)：接收上一步结果并返回新值，可用于数据转换。
- thenAccept(Consumer)：消费结果，不返回值，适合打印或存储。
- thenRun(Runnable)：不关心结果，只在前任务完成后执行动作。
示例：
立即学习“Java免费学习笔记（深入）”；
CompletableFuture<String> result = CompletableFuture
.supplyAsync(() -> "Hello")
.thenApply(s -> s + " World")
.thenApply(String::toUpperCase);
result.thenAccept(System.out::println); // 输出: HELLO WORLD
组合多个异步任务
当需要并行执行多个任务并合并结果时，可以使用以下方法：
- thenCombine：合并两个独立的 CompletableFuture 的结果。
- thenCompose：将一个 CompletableFuture 的输出作为另一个的输入（扁平化嵌套）。
- allOf：等待所有 CompletableFuture 完成，适用于并行无依赖任务。
- anyOf：任一任务完成即触发后续操作。
示例：合并两个远程请求结果
CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> fetchUser());
CompletableFuture<String> f2 = CompletableFuture.supplyAsync(() -> fetchOrder());
CompletableFuture<String> combined = f1.thenCombine(f2, (user, order) ->
"User: " + user + ", Order: " + order
);
combined.thenAccept(System.out::println);
异常处理
异步流程中的异常不会自动抛出，必须显式处理。常用方法包括：
- exceptionally(Function)：捕获异常并提供默认值或降级逻辑。
- handle(BiFunction)：无论是否异常都能处理，接收结果和异常两个参数。
示例：
立即学习“Java免费学习笔记（深入）”；
CompletableFuture<String> faulty = CompletableFuture
.supplyAsync(() -> {
throw new RuntimeException("网络错误");
})
.exceptionally(ex -> {
System.err.println("发生异常: " + ex.getMessage());
return "默认用户";
});
faulty.thenAccept(System.out::println); // 输出: 默认用户
基本上就这些。合理使用 CompletableFuture 能显著提升程序响应性和吞吐量，尤其适合 I/O 密集型场景如 Web 请求、数据库查询等。关键是避免阻塞调用（如 get()），尽量用回调方式处理结果。
