在Java中如何实现并发任务分组执行-java教程-PHP中文网

在Java中如何实现并发任务分组执行

P粉602998670

发布： 2025-10-25 21:00:02

原创

640人浏览过

使用CompletableFuture结合ExecutorService按组并行执行任务，先将任务按groupId分组到Map中，再对每组提交异步任务并等待全部完成。

在java中如何实现并发任务分组执行

在Java中实现并发任务分组执行，关键在于将任务按组划分，并确保每组任务可以并行执行，同时组与组之间可控制执行顺序或并发级别。常用的方式是结合ExecutorService、CompletableFuture和集合分组逻辑来完成。

使用CompletableFuture进行任务分组并行处理

通过CompletableFuture可以方便地对每组任务进行异步执行，并等待整组完成。

示例场景：假设有多个任务，需要按类别（如用户ID分组）分别执行，每组内部任务并行，组间也可并行。

先将任务按某个键（如groupId）分组到Map中
对每个组创建一个CompletableFuture，内部使用线程池并行处理该组所有任务
收集所有组的future，调用join()等待全部完成

代码示例：

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

Map<String, List<Runnable>> groupedTasks = // 按组分类的任务

ExecutorService groupPool = Executors.newFixedThreadPool(4);
List<CompletableFuture<Void>> groupFutures = new ArrayList<>();

for (Map.Entry<String, List<Runnable>> entry : groupedTasks.entrySet()) {
    String groupId = entry.getKey();
    List<Runnable> tasks = entry.getValue();

    CompletableFuture<Void> groupFuture = CompletableFuture.runAsync(() -> {
        ExecutorService taskPool = Executors.newFixedThreadPool(2); // 每组内并发度
        List<CompletableFuture<Void>> taskFutures = tasks.stream()
            .map(task -> CompletableFuture.runAsync(task, taskPool))
            .collect(Collectors.toList());

        // 等待本组所有任务完成
        CompletableFuture.allOf(taskFutures.toArray(new CompletableFuture[0])).join();
        taskPool.shutdown();
    }, groupPool);

    groupFutures.add(groupFuture);
}

// 等待所有组执行完毕
CompletableFuture.allOf(groupFutures.toArray(new CompletableFuture[0])).join();

groupPool.shutdown();

登录后复制