17370845950

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

Map> groupedTasks = // 按组分类的任务

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

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

    CompletableFuture groupFuture = CompletableFuture.runAsync(() -> {
        ExecutorService taskPool = Executors.newFixedThreadPool(2); // 每组内并发度
        List> 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();

• 遍历分组map（保持顺序可用LinkedHashMap）
• 每组提交到线程池后调用future.get()同步等待