Future是Java 5提供的基础异步接口，支持任务提交与结果获取，但功能有限且get()方法阻塞；CompletableFuture自Java 8引入，实现Future和CompletionStage，支持非阻塞回调、链式调用、异常处理及任务编排，并可通过allOf或anyOf组合多个任务，还可指定自定义线程池以避免资源竞争，相比Future更灵活强大，适用于构建高效非阻塞系统。
在Java中处理异步任务时，Future 和 CompletableFuture 是两个核心类。它们都来自 java.util.concurrent 包，用于实现非阻塞的任务执行与结果获取。但两者在使用方式和功能丰富性上有显著区别。
Future：基础的异步任务接口
Future 是 Java 5 引入的接口，代表一个异步计算的结果。它允许你启动一个任务并稍后获取其结果，但功能较为有限。
使用 Future 的基本流程如下：
- 通过
ExecutorService.submit()提交一个 Callable 或 Runnable 任务，返回一个 Future 对象。 - 调用
get()方法阻塞等待结果，或使用带超时的get(long timeout, TimeUnit unit)。 - 可用
isDone()判断任务是否完成，cancel()尝试取消任务。
示例代码：
立即学习“Java免费学习笔记（深入）”；
ExecutorService executor = Executors.newFixedThreadPool(2);
Future<String> future = executor.submit(() -> {
Thread.sleep(2000);
return "Hello from Future";
});
// 阻塞直到结果返回
String result = future.get(); // 可能抛出异常
System.out.println(result);
缺点很明显：get() 是阻塞的，无法进行回调或链式处理，难以组合多个异步任务。
CompletableFuture：强大的异步编程工具
CompletableFuture 是 Java 8 引入的类，实现了 Future 和 CompletionStage 接口，提供了丰富的非阻塞式函数式编程能力。
它支持：
- 任务完成后的回调（thenApply, thenAccept, thenRun）
- 异常处理（handle, exceptionally）
- 任务编排（thenCompose, thenCombine）
- 并行执行多个任务（allOf, anyOf）
示例：链式处理异步任务
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "Hello";
})
.thenApply(s -> s + " World")
.thenApply(String::toUpperCase)
.exceptionally(ex -> "Error: " + ex.getMessage());
// 非阻塞获取结果（也可用 join()）
String result = future.get();
System.out.println(result); // 输出: HELLO WORLD
异步组合多个任务
实际开发中常需并行执行多个服务调用，并合并结果。CompletableFuture.allOf 和 anyOf 非常有用。
例如：并行查询用户信息、订单、积分
CompletableFuture<User> userFuture = CompletableFuture.supplyAsync(() -> userService.getUser(id));
CompletableFuture<Order> orderFuture = CompletableFuture.supplyAsync(() -> orderService.getOrders(id));
CompletableFuture<Points> pointsFuture = CompletableFuture.supplyAsync(() -> pointService.getPoints(id));
// 等待全部完成
CompletableFuture<Void> allDone = CompletableFuture.allOf(
userFuture, orderFuture, pointsFuture
);
// 获取结果（注意：join 不抛检査异常）
allDone.thenRun(() -> {
User user = userFuture.join();
Order order = orderFuture.join();
Points points = pointsFuture.join();
System.out.println("User: " + user.getName());
});
自定义线程池避免资源耗尽
CompletableFuture 默认使用 ForkJoinPool.commonPool()，所有应用共享该线程池。高并发下可能互相影响。
推荐：为关键业务创建独立线程池。
ExecutorService customExecutor = Executors.newThreadPoolExecutor(
4, 8, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100)
);
CompletableFuture<String> future = CompletableFuture
.supplyAsync(() -> callExternalApi(), customExecutor);
这样可控制资源隔离，避免被其他模块拖慢。
基本上就这些。CompletableFuture 提供了现代 Java 异步编程所需的核心能力，相比原始 Future 更灵活、更易组合。合理使用回调、异常处理和线程池管理，能构建高效响应的非阻塞系统。不复杂但容易忽略细节，比如异常处理和线程池选择。
