Java-CompletableFuture结合批处理、自定义线程池

将 CompletableFuture 与批处理和自定义线程池结合使用是一种常见的模式，用于高效地管理和执

行批量异步任务。下面是一个具体的示例，展示了如何使用 CompletableFuture 和自定义线程池来

执行批量异步任务，并在主线程中获取结果。

import java.util.*;
import java.util.concurrent.*;
import java.util.function.Consumer;
import java.util.stream.Collectors;public class CompletableFutureBatchProcessingExample {public static void main(String[] args) throws InterruptedException, ExecutionException {// 创建一个自定义线程池ExecutorService customThreadPool = Executors.newFixedThreadPool(4);// 创建一个数据列表List<Integer> data = IntStream.rangeClosed(1, 100).boxed().collect(Collectors.toList());// 执行批处理CompletableFuture<Void> future = batchProcessWithFuture(data, 10, customThreadPool, batch -> {// 模拟耗时操作try {Thread.sleep(1000); // 模拟每个批次耗时 1 秒} catch (InterruptedException e) {t