在Java中如何使用CompletableFuture.allOf组合任务-java教程-PHP中文网

在Java中如何使用CompletableFuture.allOf组合任务

P粉602998670

发布： 2025-11-16 18:03:06

原创

716人浏览过

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

在java中如何使用completablefuture.allof组合任务

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

基本用法

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

示例代码：

import java.util.concurrent.CompletableFuture;

public class AllOfExample {
    public static void main(String[] args) {
        // 创建三个异步任务
        CompletableFuture<Void> task1 = CompletableFuture.runAsync(() -> {
            System.out.println("任务1开始");
            sleep(1000);
            System.out.println("任务1完成");
        });

        CompletableFuture<Void> task2 = CompletableFuture.runAsync(() -> {
            System.out.println("任务2开始");
            sleep(2000);
            System.out.println("任务2完成");
        });

        CompletableFuture<Void> task3 = CompletableFuture.runAsync(() -> {
            System.out.println("任务3开始");
            sleep(1500);
            System.out.println("任务3完成");
        });

        // 使用 allOf 等待所有任务完成
        CompletableFuture<Void> 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免费学习笔记（深入）”；

AutoIt3 中文帮助文档打包

AutoIt v3 版本, 这是一个使用类似 BASIC 脚本语言的免费软件, 它设计用于 Windows GUI(图形用户界面)中进行自动化操作. 利用模拟键盘按键, 鼠标移动和窗口/控件的组合来实现自动化任务. 而这是其它语言不可能做到或无可靠方法实现的(比如VBScript和SendKeys). AutoIt 非常小巧, 完全运行在所有windows操作系统上.(thesnow注:现在已经不再支持win 9x,微软连XP都能放弃, 何况一个win 9x支持), 并且不需要任何运行库. AutoIt

查看详情

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

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "结果1");
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 100);
CompletableFuture<Double> future3 = CompletableFuture.supplyAsync(() -> 3.14);

CompletableFuture<Void> 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();
    }
});

登录后复制