Java-BatchProcessingUtil结合CompletableFuture工具类

为了结合批处理与 CompletableFuture 并使用自定义线程池，我们可以创建一个功能全面的工具类

BatchProcessingUtil。这个工具类将支持以下功能：

批处理遍历列表中的每个元素。

使用自定义线程池执行批处理任务。

返回一个 CompletableFuture 对象以支持异步回调和结果处理。

支持进度跟踪。

下面是具体的实现：

BatchProcessingUtil 工具类

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
import java.util.stream.Collectors;public class BatchProcessingUtil {/*** 批处理遍历列表中的每个元素并执行指定的操作，返回一个 CompletableFuture 对象。** @param <T>         列表元素的类型* @param elements    要遍历的列表* @param batchSize   每次处理的元素数量* @param executor    自定义的线程池* @param consumer    指定的操作* @return CompletableFuture<Void> 表示所有任务完成的未来对象*