ScheduledExecutorService 未执行初始延迟为 0 的任务

Question

ScheduledExecutorService 在使用scheduleWithFixedDelay 或scheduleAtFixedRate 时未执行具有0 时间单位的initialDelay 提交的任务。但是当我在上面调用schedule 时它正在执行任务

ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
Runnable runnable = () -> System.out.println("I am a runnable");
scheduledExecutorService.schedule(runnable, 0, TimeUnit.SECONDS);
scheduledExecutorService.shutdown();

输出

I am a runnable

但是当我使用scheduleWithFixedDelay 或scheduleAtFixedRate 而不是schedule 时，任务没有得到执行。

ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
Runnable runnable = () -> System.out.println("I am a runnable");
scheduledExecutorService.scheduleWithFixedDelay(runnable, 0, 1, TimeUnit.SECONDS);
// or  scheduledExecutorService.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
scheduledExecutorService.shutdown();

为什么在这种情况下任务没有得到执行？我希望在 initialDelay 设置为 0 时执行此任务

Answer 1

您过早关闭了执行程序。这就是为什么其他线程尚未启动的原因。不保证线程会先启动然后关闭方法。

如果您使用 awaitTermination，您将看到输出。

scheduledExecutorService.awaitTermination(1, TimeUnit.MILLISECONDS);

//输出：我是一个runnable

Answer 2

您对ExecutorService#shutdown 的调用将停止任何进一步的任务安排。显然，您的调用发生得如此之快，以至于调度程序永远无法执行计划任务的第一次运行。这是有道理的。

不太有意义的是为什么对schedule 的调用恰好被安排得足够快以在关机前及时执行其任务，但对scheduleWithFixedDelay 或scheduleAtFixedRate 的调用却延迟为零没有尽快安排。显然，scheduleWithFixedDelay 和 scheduleAtFixedRate 调用中存在一些开销，这些开销足以让程序在它们有机会进行第一次执行之前退出。

无论如何，您可以在我的代码版本running live at IdeOne.com 中看到该行为。添加这一行：

Thread.sleep( 1_000 * 5 ) ;

...在您关机之前有足够的时间执行某些scheduleWithFixedDelay 和scheduleAtFixedRate 任务。

或者通过添加对awaitTermination 的调用来查看相同的效果，如correct Answer by Nguyen 所示。

Answer 3

背后的原因可以在ScheduledThreadPoolExecutor中找到，也就是Executors.newSingleThreadScheduledExecutor()的实现类

1。调用schedule时执行任务，

这是由于executeExistingDelayedTasksAfterShutdown is true by default

    /**
     * False if should cancel non-periodic not-yet-expired tasks on shutdown.
     */
    private volatile boolean executeExistingDelayedTasksAfterShutdown = true;

2。没有为 scheduleWithFixedDelay 或 scheduleAtFixedRate 执行任务

这是由于continueExistingPeriodicTasksAfterShutdown is false by default

    /**
     * False if should cancel/suppress periodic tasks on shutdown.
     */
    private volatile boolean continueExistingPeriodicTasksAfterShutdown;

我们可以在调度任务之前通过ScheduledThreadPoolExecutor#setExecuteExistingDelayedTasksAfterShutdownPolicy和ScheduledThreadPoolExecutor#setContinueExistingPeriodicTasksAfterShutdownPolicy覆盖这些参数。

Answer 4

为什么shutdown被立即调用，schedule可以执行这个任务，而scheduleAtFixedRate不执行这个任务？

如果使用scheduleAtFixedRate，则此任务为Periodic，默认keepPeriodic策略为false，因此在调用shutdown时，此任务将从工作队列中移除。

但是使用schedule并没有执行移除任务的逻辑。（isPeriodic为假）

见ScheduledThreadPoolExecutor#onShutdown:

        @Override void onShutdown() {
        BlockingQueue<Runnable> q = super.getQueue();
        boolean keepDelayed =
            getExecuteExistingDelayedTasksAfterShutdownPolicy();
        boolean keepPeriodic =
            getContinueExistingPeriodicTasksAfterShutdownPolicy();
        // Traverse snapshot to avoid iterator exceptions
        // TODO: implement and use efficient removeIf
        // super.getQueue().removeIf(...);
        for (Object e : q.toArray()) {
            if (e instanceof RunnableScheduledFuture) {
                RunnableScheduledFuture<?> t = (RunnableScheduledFuture<?>)e;
                if ((t.isPeriodic()
                     ? !keepPeriodic
                     : (!keepDelayed && t.getDelay(NANOSECONDS) > 0))
                    || t.isCancelled()) { // also remove if already cancelled
                    if (q.remove(t))
                        t.cancel(false);
                }
            }
        }
        tryTerminate();
    }

所以我认为 Basil Bourque 的回答的解释是不准确的：

在 scheduleWithFixedDelay 和 scheduleAtFixedRate 调用中显然存在一些开销，这些开销足以使程序在有机会进行首次执行之前退出。

这不是因为程序在他们有机会进行第一次执行之前就退出了，而是因为线程池中的工作线程没有得到任务（它被删除了，），然后线程池停止了。此时，程序退出。如果任务没有被移除，程序不会立即退出。只有当线程池中的工作线程完成工作队列中的任务时，程序才会退出。 （因为线程池中的工作线程不是守护线程）。