17370845950

CompletableFuture的allOf等待所有任务完成，anyOf在任一任务完成后即响应；allOf返回Void需手动获取各结果，anyOf返回Object需类型转换，二者均不自动处理异常，需结合exceptionally或handle方法管理错误，适用于并行任务协调与快速响应场景。

在Java中，CompletableFuture 是处理异步编程的重要工具。当我们需要同时处理多个异步任务时，allOf 和 anyOf 方法能帮助我们更方便地协调这些任务的执行和结果获取。

CompletableFuture.allOf：等待所有任务完成

allOf 用于等待一组 CompletableFuture 全部完成。它返回一个 CompletableFuture，当所有传入的任务都执行完毕后，这个返回的 future 才会完成。

注意：allOf 不会合并结果，你需要手动获取每个 future 的结果。

使用场景示例：

• 发起多个远程API调用，等全部返回后再处理聚合数据
• 并行执行多个独立任务，确保它们都完成后才继续

代码示例：

CompletableFuture task1 = CompletableFuture.supplyAsync(() -> {
    // 模拟耗时操作
    sleep(1000);
    return "Result1";
});

CompletableFuture task2 = CompletableFuture.supplyAsync(() -> {
    sleep(800);
    return "Result2";
});

CompletableFuture task3 = CompletableFuture.supplyAsync(() -> {
    sleep(1200);
    return "Result3";
});

// 等待所有任务完成
CompletableFuture allDone = CompletableFuture.allOf(task1, task2, task3);

// 在所有任务完成后处理结果
allDone.thenRun(() -> {
    try {
        String r1 = task1.get(); // 获取结果
        String r2 = task2.get();
        String r3 = task3.get();
        System.out.println("All results: " + r1 + ", " + r2 + ", " + r3);
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
});

如果其中一个任务失败，allOf 返回的 future 也会失败。你可以通过 whenComplete 或 handle 来处理异常情况。

CompletableFuture.anyOf：任一任务完成即响应

anyOf 用于监听多个 CompletableFuture，只要其中任意一个完成（无论是正常完成还是异常完成），返回的 future 就会完成。

它返回的是 CompletableFuture，因为无法保证是哪个任务先完成，类型只能是 Object，需要手动转型。

使用场景示例：

• 从多个数据源查询同一数据，取最快返回的结果
• 提供备用服务调用，主服务超时前若备选完成可提前响应

代码示例：

CompletableFuture fastTask = CompletableFuture.supplyAsync(() -> {
    sleep(500);
    return "Fast result";
});

CompletableFuture slowTask = CompletableFuture.supplyAsync(() -> {
    sleep(2000);
    return "Slow result";
});

CompletableFuture