使用 ScheduledExecutorService 方法定期运行一批任务



我想一次提交一批任务,并定期执行它们。使用ExecutorService对象和invokeall方法,可以一次运行任务。但是尝试使用scheduleAtFixedRate,它是不兼容的:

executor.scheduleAtFixedRate(executor.invokeAll(callables), initialDelay, period, TimeUnit.SECONDS );

如何一次定期执行一批任务?

没有什么比invokeall,但是通过你的可运行对象循环没有错,因为现实中也没有像"一次"这样的

ScheduledExecutorService pool = Executors.newScheduledThreadPool(10);
for (int i = 0; i < 10; i++) {
    pool.scheduleAtFixedRate(() -> {
        // do some work
    }, 0, 10, TimeUnit.SECONDS);
}

或者,如果您有Runnable集合:

ScheduledExecutorService pool = Executors.newScheduledThreadPool(runnables.size());
runnables.forEach((r) -> pool.scheduleAtFixedRate(r, 0, 10, TimeUnit.SECONDS));

相关内容

  • 没有找到相关文章

最新更新