如何从另一个任务中取消 ScheduledFuture 任务并优雅地结束？

Question

我在玩ScheduledExecutorService。我想要做的是启动一个简单的ticker（每秒一个tick）并稍后安排另一个任务（五秒后）取消第一个任务。然后阻塞主线程直到一切都完成，这应该是在两个任务完成之后（+- 5 秒）。

这是我的代码：

ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
Runnable tickTask = () -> System.out.println("Tick");
ScheduledFuture<?> scheduledTickTask = executor.scheduleAtFixedRate(tickTask, 0, 1, TimeUnit.SECONDS);
Runnable cancelTask = () -> scheduledTickTask.cancel(true);
executor.schedule(cancelTask, 5, TimeUnit.SECONDS);
executor.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);

让我吃惊的问题是它会阻塞，就好像还有一些正在运行的任务一样。为什么？ cancelTask 应该立即结束，而 scheduledTickTask 刚刚取消，那么问题出在哪里？

Answer 1

根据 ExecutorService.awaitTermination 的 Javadoc（强调我的）：

阻塞，直到所有任务完成执行关闭请求后，或发生超时，或当前线程被中断，以先发生者为准。

这意味着您需要先致电shutdown，如下所示：

ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
Runnable tickTask = () -> System.out.println("Tick");
ScheduledFuture<?> scheduledTickTask = executor.scheduleAtFixedRate(tickTask, 0, 1, TimeUnit.SECONDS);
Runnable cancelTask = () -> {
    scheduledTickTask.cancel(true);
    executor.shutdown();
};
executor.schedule(cancelTask, 5, TimeUnit.SECONDS);
executor.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);

在您的情况下，超时永远不会发生，因为您实际上将其设置为“无限”并且当前线程没有被中断。