1. 引言
在现代 Java 开发中，异步编程已成为提升系统吞吐量和响应速度的关键手段。CompletableFuture 是 Java 8 引入的异步编程工具，它弥补了 Future 的不足，提供了函数式编程风格的异步编排能力。本文将从基础概念出发，结合实际代码示例，带你掌握 CompletableFuture 的核心用法与实战技巧。
2. CompletableFuture 基础
2.1 什么是 CompletableFuture
CompletableFuture 实现了 Future 和 CompletionStage 接口，代表一个异步计算的结果。与传统的 Future 相比，它支持手动完成计算、回调注册以及多个异步任务的组合编排。
2.2 创建 CompletableFuture
创建 CompletableFuture 的常用方式有以下几种：
// 方式一：使用 supplyAsync 提交有返回值的异步任务 CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> { return "Hello"; }); // 方式二：使用 runAsync 提交无返回值的异步任务 CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> { System.out.println("Running async task"); }); // 方式三：指定自定义线程池 ExecutorService executor = Executors.newFixedThreadPool(4); CompletableFuture<String> future3 = CompletableFuture.supplyAsync(() -> { return "Custom pool"; }, executor);3. 核心方法详解
3.1 任务回调
CompletableFuture 提供了丰富的回调方法，用于在任务完成后执行后续操作：
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello"); // thenApply：转换结果 CompletableFuture<Integer> lengthFuture = future.thenApply(String::length); // thenAccept：消费结果，无返回值 future.thenAccept(result -> System.out.println("Result: " + result)); // thenRun：任务完成后执行，不关心结果 future.thenRun(() -> System.out.println("Task completed"));3.2 异常处理
异步任务可能抛出异常，CompletableFuture 提供了优雅的异常处理机制：
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { if (Math.random() > 0.5) { throw new RuntimeException("Something went wrong"); } return "Success"; }); // exceptionally：发生异常时返回默认值 CompletableFuture<String> safeFuture = future.exceptionally(ex -> "Fallback value"); // handle：无论成功失败都处理 CompletableFuture<String> handledFuture = future.handle((result, ex) -> { if (ex != null) { return "Error: " + ex.getMessage(); } return result; });3.3 任务组合
多个 CompletableFuture 可以灵活组合，实现复杂的异步编排：
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello"); CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "World"); // thenCombine：合并两个任务的结果 CompletableFuture<String> combined = future1.thenCombine(future2, (a, b) -> a + " " + b); // allOf：等待所有任务完成 CompletableFuture<Void> allFutures = CompletableFuture.allOf(future1, future2); // anyOf：任意一个任务完成即返回 CompletableFuture<Object> anyFuture = CompletableFuture.anyOf(future1, future2);4. 实战案例：并行查询与结果聚合
下面通过一个实际场景演示 CompletableFuture 的威力——同时查询多个数据源并聚合结果：
import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.List; import java.util.stream.Collectors; public class ParallelQueryDemo { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(4); // 模拟三个远程服务调用 CompletableFuture<String> userFuture = CompletableFuture.supplyAsync(() -> fetchUser(), executor); CompletableFuture<String> orderFuture = CompletableFuture.supplyAsync(() -> fetchOrders(), executor); CompletableFuture<String> productFuture = CompletableFuture.supplyAsync(() -> fetchProducts(), executor); // 聚合所有结果 CompletableFuture<String> resultFuture = CompletableFuture.allOf(userFuture, orderFuture, productFuture) .thenApply(v -> { String user = userFuture.join(); String orders = orderFuture.join(); String products = productFuture.join(); return String.format("用户信息: %s\n订单: %s\n商品: %s", user, orders, products); }); // 设置超时与异常处理 String result = resultFuture .exceptionally(ex -> "查询失败: " + ex.getMessage()) .join(); System.out.println(result); executor.shutdown(); } private static String fetchUser() { sleep(1000); return "张三"; } private static String fetchOrders() { sleep(1500); return "订单#1001, 订单#1002"; } private static String fetchProducts() { sleep(800); return "商品A, 商品B, 商品C"; } private static void sleep(long millis) { try { Thread.sleep(millis); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }5. 性能与最佳实践
5.1 线程池选择
CompletableFuture 默认使用 ForkJoinPool.commonPool()，但在生产环境中建议自定义线程池，避免公共线程池被阻塞影响其他任务。根据任务类型选择合适的线程池：
- CPU 密集型：线程数设为 CPU 核心数 + 1
- IO 密集型：线程数可适当增加，如 2 * CPU 核心数
5.2 避免阻塞主线程
在 Web 应用中使用 CompletableFuture 时，应避免在请求处理线程中调用 join() 或 get() 阻塞等待。推荐的做法是将 CompletableFuture 直接返回给框架，由框架异步处理响应。
5.3 超时处理
Java 9 引入了 orTimeout 和 completeOnTimeout 方法，可以方便地设置超时：
// Java 9+ 超时处理 CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> longRunningTask()) .orTimeout(5, TimeUnit.SECONDS) .exceptionally(ex -> "Timeout occurred");6. 总结
CompletableFuture 为 Java 异步编程提供了强大的支持，通过函数式风格的 API 可以轻松实现任务的异步执行、回调处理、异常管理和复杂编排。掌握 CompletableFuture 的核心用法，能够帮助开发者编写出更高效、更易维护的并发代码。建议在实际项目中多加练习，结合业务场景灵活运用。
