17370845950

CompletableFuture.allOf用于并行执行多个异步任务并等待全部完成，返回CompletableFuture表示完成状态，不包含结果，需单独获取各任务结果，适用于批量调用接口等场景。

在Java中，当你需要并行执行多个异步任务，并等待它们全部完成时，可以使用 CompletableFuture.allOf。它接收多个 CompletableFuture 实例，返回一个新的 CompletableFuture，该实例会在所有传入的任务都完成后才完成。

基本用法

CompletableFuture.allOf 接收可变数量的 CompletableFuture 参数，返回一个 CompletableFuture。这个返回的 future 只表示“全部完成”，不包含组合结果。

示例代码：

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 的结果。

示例：获取多个任务的结果

CompletableFuture future1 = 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 是并行协调多个异步任务的简洁方式，特别适合“等待所有请求结束”的场景，比如批量调用外部接口、预加载资源等。只要记得结果需要单独获取就行。