CompletableFuture通过链式调用实现异步任务组合，支持串行执行（thenApply）、并行合并（thenCombine）与异常处理（exceptionally），提升Java异步编程的可读性与效率。
在Java异步编程中，CompletableFuture 是实现任务链式调用的核心工具。它允许你以非阻塞方式组合多个异步操作，提升程序响应性和吞吐量。通过链式调用，你可以将多个依赖或并行的任务串联起来，形成清晰的执行流程。
基本概念：什么是CompletableFuture？
CompletableFuture 是 Java 8 引入的 Future 的增强版本，实现了 Future 和 CompletionStage 接口。它支持主动完成（complete）、异常处理、任务回调和组合操作。
相比传统 Future 需要手动阻塞获取结果，CompletableFuture 提供了丰富的回调方法，比如 thenApply、thenAccept、thenRun 等，实现真正的异步非阻塞编程。
链式调用：串行任务组合
当你有一系列任务需要按顺序执行，且后一个任务依赖前一个的结果时，可以使用 thenApply 或 thenCompose 实现链式调用。
立即学习“Java免费学习笔记（深入）”；
- thenApply(Function)：接收上一阶段结果并返回新值，用于数据转换。
- thenCompose(Function)：适用于返回另一个 CompletableFuture 的场景，实现扁平化链式调用。
示例：用户ID → 获取用户 → 查询订单 → 计算总价
CompletableFuture<Integer> future = CompletableFuture
.supplyAsync(() -> fetchUserId()) // 第一步：获取用户ID
.thenApply(userId -> fetchUser(userId)) // 第二步：根据ID查用户
.thenApply(user -> fetchOrders(user.getId())) // 第三步：查订单
.thenApply(orders -> calculateTotal(orders)); // 第四步：计算总金额
Integer total = future.join(); // 获取最终结果（会等待完成）
并行与合并：组合多个异步任务
当多个任务可以并行执行，并需要合并结果时，使用 thenCombine 或 allOf。
- thenCombine：合并两个异步任务的结果。
- allOf：等待所有 CompletableFuture 完成（注意返回的是 void）。
示例：同时加载用户信息和商品推荐，最后合并展示
CompletableFuture<UserProfile> userFuture =
CompletableFuture.supplyAsync(() -> loadUserProfile());
CompletableFuture<List<Product>> recommendFuture =
CompletableFuture.supplyAsync(() -> recommendProducts());
CompletableFuture<Dashboard> dashboardFuture =
userFuture.thenCombine(recommendFuture, (user, products) ->
new Dashboard(user, products));
Dashboard dashboard = dashboardFuture.join();
异常处理：让链式更健壮
异步链中任何一个环节出错都会导致整个流程中断。使用 exceptionally 或 handle 可捕获异常并提供默认值或恢复逻辑。
- exceptionally(Function)：仅在发生异常时触发，返回默认结果。
- handle(BiFunction)：无论成功或失败都会执行，适合统一处理结果和异常。
示例：即使订单查询失败，也返回0作为总价
CompletableFuture<Integer> safeTotal = fetchOrdersFuture
.thenApply(orders -> calculateTotal(orders))
.exceptionally(ex -> {
System.err.println("计算失败: " + ex.getMessage());
return 0;
});
基本上就这些。CompletableFuture 的链式调用让Java异步编程变得简洁而强大。合理使用 thenApply、thenCombine、exceptionally 等方法，能有效组织复杂异步逻辑，避免回调地狱，同时保持代码可读性。实际开发中建议配合自定义线程池使用，避免阻塞ForkJoinPool公共池。
