在提交给执行者服务的任务之间有延迟

Question

我正在使用sping-boot，我有这样一个用例，我想将列表的每个元素提交给执行器服务（线程池大小=4）。但是在每个必须处理的元素之间，我想要1秒钟的延迟。

Thread.sleep（1000）不工作，因为执行程序一睡觉就启动另一个线程。

        list().forEach(key -> {
            executorService.submit(new Runnable() {
                @Override
                public void run() {
                    process(key);
                }
            });
        });

编辑：这是我的process（）方法，我在最后尝试使用sleep，但没有成功。

    private void process(long key) {
        try {
            //processing key

        } catch (SystemException e) {
            // Exception handling
        }
        Thread.sleep(1000);
    }

Answer 1

既然希望它们在另一个线程上按顺序执行，为什么不使用ScheduledExecutorService并轮询列表呢？

伪

java prettyprint-override">Iterator<Pojo> iterator = list().iterator();

Future<Pojo> future = executorService.schedule(() -> {
    if (!iterator.hasNext()) {
        future.cancel(false);
        return;
    }
    Pojo pojo = iterator.next();
    
    iterator.remove();

    process(pojo.key());
}