CompletableFuture.allOf用于并行执行多个异步任务并等待全部完成，返回CompletableFuture表示完成状态，不包含结果，需单独获取各任务结果，适用于批量调用接口等场景。
在Java中，当你需要并行执行多个异步任务，并等待它们全部完成时，可以使用 CompletableFuture.allOf。它接收多个 CompletableFuture 实例，返回一个新的 CompletableFuture，该实例会在所有传入的任务都完成后才完成。
基本用法
CompletableFuture.allOf 接收可变数量的 CompletableFuture 参数，返回一个 CompletableFuture
示例代码：
import java.util.concurrent.CompletableFuture;
public class AllOfExample {
public static void main(String[] args) {
// 创建三个异步任务
CompletableFuture task1 = CompletableFuture.runAsync(() -> {
System.out.println("任务1开始");
sleep(1000);
System.out.println("任务1完成");
});
CompletableFuture task2 = CompletableFuture.runAsync(() -> {
System.out.println("任务2开始");
sleep(2000);
System.out.println("任务2完成");
});
CompletableFuture task3 = CompletableFuture.runAsync(() -> {
System.out.println("任务3开始");
sleep(1500);
System.out.println("任务3完成");
});
// 使用 allOf 等待所有任务完成
CompletableFuture allDone = CompletableFuture.allOf(task1, task2, task3);
// 在所有任务完成后执行操作
allDone.thenRun(() -> {
System.out.println("所有任务已完成！");
});
// 主线程等待足够时间，让异步任务完成
sleep(3000);
}
private static void sleep(long millis) {
try {
Thread.sleep(millis);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
} 处理有返回值的任务
如果任务是 supplyAsync 类型（有返回值），allOf 依然适用，但你需要手动获取每个 future 的结果。
立即学习“Java免费学习笔记（深入）”；
示例：获取多个任务的结果
CompletableFuturefuture1 = CompletableFuture.supplyAsync(() -> "结果1"); CompletableFuture future2 = CompletableFuture.supplyAsync(() -> 100); CompletableFuture future3 = CompletableFuture.supplyAsync(() -> 3.14); CompletableFuture allDone = CompletableFuture.allOf(future1, future2, future3); // 获取结果（注意：get() 是阻塞的） allDone.thenRun(() -> { try { String r1 = future1.get(); // 得到 "结果1" Integer r2 = future2.get(); // 得到 100 Double r3 = future3.get(); // 得到 3.14 System.out.println("汇总结果: " + r1 + ", " + r2 + ", " + r3); } catch (Exception e) { e.printStackTrace(); } });
注意事项
使用 allOf 时需要注意以下几点：
- allOf 返回的 future 不携带结果，只是通知“全部完成”
- 如果其中一个任务失败，allOf 返回的 future 也会失败
- 调用 get() 获取结果时会阻塞，建议使用 thenApply、thenAccept 等非阻塞方式处理结果
- 任务是并行执行的，依赖于使用的 Executor（默认 ForkJoinPool）
基本上就这些。CompletableFuture.allOf 是并行协调多个异步任务的简洁方式，特别适合“等待所有请求结束”的场景，比如批量调用外部接口、预加载资源等。只要记得结果需要单独获取就行。
