贴代码吧，简单封装了一个分批次操作数据的工具类，依赖Hutool和Lombok，少写几行代码偷偷懒

    1. package org.ssh.boot.pay.util;
    3. import cn.hutool.core.collection.CollUtil;
    4. import cn.hutool.core.thread.ThreadUtil;
    5. import lombok.extern.slf4j.Slf4j;
    7. import java.util.List;
    8. import java.util.concurrent.CompletableFuture;
    10. /**
    11.  * 批量处理数据工具类
    12.  */
    13. @Slf4j
    14. public class BatchDataUtils {
    16.     private final static int BATCH_SIZE = 1000;
    18.     /**
    19.      * 分批次处理数据 <br>
    20.      * 默认每个批次1000条数据
    21.      * @param list
    22.      * @param handler
    23.      * @param <T>
    24.      */
    25.     public static <T> void batchHandle(List<T> list, BatchHandle<T> handler) {
    26.         batchHandle(list, BATCH_SIZE, handler);
    27.     }
    29.     /**
    30.      * 分批次处理数据
    31.      * @param list
    32.      * @param handler
    33.      * @param <T>
    34.      * @return
    35.      */
    36.     public static <T> void batchHandle(List<T> list, int maxSize, BatchHandle<T> handler) {
    37.         if (CollUtil.isEmpty(list)) {
    38.             return;
    39.         }
    40.         List<List<T>> splitList = CollUtil.split(list, maxSize);
    41.         CompletableFuture<Void> cf = CompletableFuture.runAsync(() -> {
    42.             for (List<T> tList : splitList) {
    43.                 handler.handle(tList);
    44.             }
    45.         }, ThreadUtil.newExecutor(4, 8));
    46.         try {
    47.             cf.get();
    48.         } catch (Exception e) {
    49.             log.error("批量处理数据异常", e);
    50.             throw new RuntimeException(e);
    51.         }
    52.         cf.thenRun(() -> {
    53.             log.info("批量处理完成");
    54.         });
    55.     }
    57.     public interface BatchHandle<T> {
    58.         void handle(List<T> list);
    59.     }
    61. }

    如何使用呢，再贴一段代码。
    这里利用Java8的lambda机制，一行代码实现分批次录入数据

    1. BatchDataUtils.batchHandle(hisReconciliationList, (list) -> hisReconciliationDao.saveAll(list));