CompletableFuture提供声明式异步编程，支持链式调用、任务组合与异常处理，通过supplyAsync/runAsync执行任务，结合thenApply/thenCombine实现串行或并行编排，使用exceptionally/handle处理错误，推荐自定义线程池以提升性能。
在现代Java应用开发中，异步编程已成为提升系统吞吐量和响应速度的关键手段。传统的多线程方式虽然可行，但代码复杂、难以管理回调和异常。Java 8引入的 CompletableFuture 类，为异步任务执行提供了强大且简洁的API支持，极大简化了并发编程的实现。
CompletableFuture简介
CompletableFuture 是对 Future 的增强，实现了 Future 和 CompletionStage 接口。它允许你以声明式的方式组合多个异步操作，支持链式调用、回调处理、异常处理以及任务编排。
相比原始的 Future，CompletableFuture 提供了以下优势：
- 支持非阻塞的回调机制（如 thenApply、thenAccept、thenRun）
- 可组合多个异步任务（thenCompose、thenCombine）
- 支持任务完成时的处理（whenComplete、exceptionally）
- 可以手动完成任务（complete 方法）
- 支持自定义线程池执行
基本异步任务执行
使用 CompletableFuture.supplyAsync() 可启动一个有返回值的异步任务，而 runAsync() 用于无返回值的任务。
立即学习“Java免费学习笔记（深入）”；
// 示例：异步获取用户信息
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return "User Data";
});
// 非阻塞地处理结果
future.thenAccept(data -> System.out.println("Received: " + data));
默认情况下，这些任务使用 ForkJoinPool.commonPool() 线程池。生产环境中建议传入自定义线程池，避免阻塞公共池中的其他任务。
ExecutorService executor = Executors.newFixedThreadPool(4);
CompletableFuture<Integer> asyncTask = CompletableFuture.supplyAsync(() -> {
return 2 + 3;
}, executor);
// 记得关闭线程池
executor.shutdown();
任务编排与组合
实际业务中，往往需要多个异步任务协同工作。CompletableFuture 提供了多种组合方式：
串行执行（thenApply / thenCompose）
CompletableFuture<String> result = CompletableFuture
.supplyAsync(() -> "Hello")
.thenApply(s -> s + " World")
.thenApply(String::toUpperCase);
并行执行并合并结果（thenCombine）
CompletableFuture<Integer> task1 = CompletableFuture.supplyAsync(() -> 10);
CompletableFuture<Integer> task2 = CompletableFuture.supplyAsync(() -> 20);
CompletableFuture<Integer> sum = task1.thenCombine(task2, Integer::sum);
sum.thenAccept(total -> System.out.println("Sum: " + total)); // 30
多个任务全部完成（allOf）或任一完成（anyOf）
CompletableFuture<Void> allDone = CompletableFuture.allOf(task1, task2);
allDone.thenRun(() -> System.out.println("All tasks completed."));
异常处理机制
异步任务中的异常不会自动抛出，必须通过 exceptionally 或 handle 方法显式处理。
CompletableFuture<String> faulty = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("Something went wrong");
});
faulty
.exceptionally(ex -> {
System.err.println("Error: " + ex.getMessage());
return "Fallback Value";
})
.thenAccept(System.out::println); // 输出 Fallback Value
也可以使用 handle(BiFunction<T, Throwable, R>) 同时处理正常结果和异常：
CompletableFuture<String> handled = future.handle((result, ex) -> {
if (ex != null) {
return "Error occurred: " + ex.getMessage();
}
return "Success: " + result;
});
基本上就这些。掌握 CompletableFuture 的核心方法后，就能写出高效、清晰的异步代码，适用于IO密集型服务调用、批量数据处理等场景。关键是理解其非阻塞特性，合理使用线程池，避免资源竞争和内存泄漏。 
