Java中如何按间隔顺序执行列表内的每一项操作

方案选型建议 #

不推荐使用TimerTask实现，核心原因是Timer是单线程模型，单个任务执行异常会直接终止整个Timer的所有调度任务，且5分钟级的长任务阻塞会导致后续所有任务延迟，稳定性远低于JUC包提供的ScheduledExecutorService，优先选择后者实现。

核心需求适配实现逻辑 #

• 首先保证List的线程安全：因为List会被多线程共同访问，需要先把原始List包装为线程安全实现，可选Collections.synchronizedList()包装ArrayList，或者读多写少场景直接用CopyOnWriteArrayList，避免并发读写触发并发修改异常。
• 串行执行保证：不要给每个Item单独提交调度任务，而是提交一个串行遍历处理的总任务到调度器，任务内部按顺序遍历List元素，处理完一个再处理下一个，天然保证不会并行执行。
• 单次执行保证：如果只需要全量执行一次，直接提交单次任务即可；如果需要周期性触发全量处理，选择scheduleWithFixedDelay而非scheduleAtFixedRate，保证上一次全量处理完全结束后再启动下一轮调度，避免长任务执行超期导致任务堆叠。

代码示例 #

1. 线程安全List初始化 #

// 读写均衡场景用synchronizedList包装
List<Item> itemList = Collections.synchronizedList(new ArrayList<>());
// 读多写少场景直接用CopyOnWriteArrayList
// List<Item> itemList = new CopyOnWriteArrayList<>();

2. 处理任务定义 #

public class ItemProcessTask implements Runnable {
    private final List<Item> itemList;

    public ItemProcessTask(List<Item> itemList) {
        this.itemList = itemList;
    }

    @Override
    public void run() {
        // synchronizedList遍历必须手动加锁，避免遍历过程中列表被修改
        synchronized (itemList) {
            for (Item item : itemList) {
                try {
                    // 执行单Item的自定义操作，支持5分钟级长耗时
                    processItem(item);
                } catch (Exception e) {
                    // 单个元素处理异常内部捕获，不影响后续元素执行
                    e.printStackTrace();
                    // 可自行扩展异常处理逻辑，比如记录失败元素、重试等
                }
            }
        }
    }

    private void processItem(Item item) {
        // 实现你自己的业务处理逻辑
    }
}

3. 调度器启动 #

// 初始化单线程调度器即可，因为是串行处理不需要多线程
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

// 仅需执行一次全量处理的场景，直接提交单次任务
scheduler.submit(new ItemProcessTask(itemList));

// 需要周期性执行的场景示例：首次无延迟启动，上一次全量处理结束后间隔1小时再启动下一轮
// scheduler.scheduleWithFixedDelay(new ItemProcessTask(itemList), 0, 1, TimeUnit.HOURS);

注意事项 #

• 单个Item处理的异常必须在循环内部捕获，避免单个元素处理失败导致整个遍历终止，剩余元素未被处理。
• 使用Collections.synchronizedList时，遍历操作必须手动对List对象加锁，否则遍历过程中列表被修改会抛出ConcurrentModificationException。
• 调度器不需要使用时要调用shutdown()方法释放资源，避免内存泄漏。
• 处理过程中需要动态增删List元素时，直接操作线程安全的List实例即可，下一轮遍历会自动拿到最新的列表内容。

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