Java如何实现每处理完指定批次后递归调用方法执行下一批任务？

核心优化逻辑 #

原有实现的核心问题是休眠逻辑触发时机错误，且没有每批次清理持久化上下文缓存，这才是OOM的核心诱因。正确逻辑为：每处理完指定批次数量的记录后，先提交当前批次、清理缓存释放内存，再执行休眠，再处理下一批。

原生无依赖实现方案 #

// 配置参数
final int BATCH_SIZE = 500;
final long SLEEP_TIME_MS = 2 * 60 * 1000; // 2分钟
int count = 0;

while (itr.hasNext()) {
    item.setValue("xxx ", xxx);
    session.save(item);
    count++;
    
    // 达到批次阈值时执行批次收尾
    if (count % BATCH_SIZE == 0) {
        session.flush(); // 把缓存中的变更刷到数据库
        session.clear(); // 清理session缓存，释放内存，避免OOM
        // 可选：提交当前事务，避免长事务占用数据库资源
        Thread.sleep(SLEEP_TIME_MS);
    }
}
// 处理最后一批不足500条的剩余数据
if (count > 0) {
    session.flush();
    session.clear();
    // 可选：提交最终事务
}

可复用的API/工具选型 #

如果不想手动实现计数、重试、容错逻辑，可以用成熟的工具库：

• Spring Batch：内置Chunk分块处理能力，直接配置批次大小、间隔等待时间、失败重试策略，自带内存清理逻辑，适配绝大多数持久化框架
• MyBatis/MyBatis Plus：内置batchUpdate方法，支持自定义批次大小，自动完成分批次提交和缓存清理
• Guava RateLimiter：用于流量控制，可直接限制每秒处理的记录数，避免短时间内生成大量对象占满内存

注意事项 #

• 必须每批次清理持久化框架的一级缓存，仅分批不清理缓存依然会出现OOM问题
• 建议增加批次失败重试、异常记录逻辑，避免单条数据异常导致整个批量任务中断
• 休眠时长可结合数据库运行负载动态调整，不需要强制写死2分钟

内容的提问来源于stack exchange，提问作者ezhil