CompletableFuture是Java 8引入的异步编程核心工具，支持非阻塞任务执行与链式组合操作。通过supplyAsync/runAsync创建有无返回值的异步任务，thenApply/thenAccept/thenRun实现结果转换与消费，thenCompose串行组合依赖任务，thenCombine并行合并独立任务结果，exceptionally/handle统一处理异常，结合自定义线程池可优化资源控制，提升I/O密集型场景性能。
在Java中，CompletableFuture 是实现异步编程的核心工具之一。它属于 java.util.concurrent 包，自 Java 8 引入，不仅支持非阻塞地执行任务，还能方便地组合多个异步操作、处理结果或异常。相比传统的 Future，CompletableFuture 提供了更丰富的 API 来链式调用和回调处理。
创建异步任务
你可以使用 CompletableFuture.supplyAsync() 或 runAsync() 启动一个异步任务：
- supplyAsync：用于有返回值的异步任务
- runAsync：用于无返回值的异步任务（返回 void）
// 有返回值的异步操作 CompletableFuturefuture = CompletableFuture.supplyAsync(() -> { // 模拟耗时操作 try { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return "Hello from async thread"; }); // 获取结果（会阻塞直到完成） String result = future.get(); // 输出: Hello from async thread
链式调用与结果处理
通过链式方法可以对异步结果进行转换和处理，常用方法包括 thenApply、thenAccept 和 thenRun。
- thenApply：接收上一步结果并返回新的结果
- thenAccept：接收结果但不返回值（消费型）
- thenRun：不接收参数，仅在前一步完成后执行
CompletableFuture.supplyAsync(() -> "Hello")
.thenApply(s -> s + " World") // 转换结果
.thenAccept(System.out::println) // 打印结果
.thenRun(() -> System.out.println("Done")); // 最终动作
组合多个异步操作
你可以将多个 CompletableFuture 组合起来，控制它们的执行顺序或并发行为。
立即学习“Java免费学习笔记（深入）”；
- thenCompose：串行组合两个依赖的异步任务（flatMap 风格）
- thenCombine：并行执行两个任务，并合并结果
// thenCompose 示例：第二个任务依赖第一个的结果 CompletableFuturecombined = CompletableFuture .supplyAsync(() -> "Hello") .thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " Future")); // thenCombine 示例：两个任务独立执行，结果合并 CompletableFuture combined2 = CompletableFuture .supplyAsync(() -> "Hello") .thenCombine( CompletableFuture.supplyAsync(() -> "World"), (s1, s2) -> s1 + " " + s2 );
异常处理
异步任务中发生异常不会自动抛出，必须显式处理。使用 exceptionally 或 handle 方法捕获错误。
- exceptionally：仅在发生异常时提供默认值
- handle：无论成功或失败都会执行，可用于统一处理
CompletableFuture.supplyAsync(() -> {
if (true) throw new RuntimeException("Oops!");
return "Success";
})
.exceptionally(ex -> "Fallback: " + ex.getMessage())
.thenAccept(System.out::println); // 输出: Fallback: Oops!
基本上就这些。合理使用 CompletableFuture 可以显著提升程序响应性和吞吐量，尤其是在 I/O 密集型或远程调用场景中。注意避免在计算密集型任务中滥用线程池，默认使用的是 ForkJoinPool.commonPool()，必要时可传入自定义线程池以更好控制资源。
