Java中CompletableFuture.allOf和anyOf使用-java教程-PHP中文网

Java中CompletableFuture.allOf和anyOf使用

P粉602998670

发布： 2025-10-09 12:13:01

原创

190人浏览过

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

java中completablefuture.allof和anyof使用

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

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

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

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

使用场景示例：

立即学习“Java免费学习笔记（深入）”；

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

代码示例：

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

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

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

// 等待所有任务完成
CompletableFuture<Void> 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>，因为无法保证是哪个任务先完成，类型只能是 Object，需要手动转型。

使用场景示例：

立即学习“Java免费学习笔记（深入）”；

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

代码示例：

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

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

CompletableFuture<Object> anyDone = CompletableFuture.anyOf(fastTask, slowTask);

anyDone.thenAccept(result -> {
    System.out.println("First done: " + result); // 输出: Fast result
});

登录后复制

注意：anyOf 不关心其他未完成的任务，即使有任务后续抛出异常也不会影响已触发的回调。如果你需要处理异常，建议在原始 future 上使用 exceptionally 或 handle。