如何从ScheduledExecutorService中移除一个任务？

Question

我有一个 ScheduledExecutorService ，能够定期计时几个不同的任务，使用scheduleAtFixedRate(Runnable, INIT_DELAY, ACTION_DELAY, TimeUnit.SECONDS);函数。

我还有另一个与此调度程序一起使用的Runnable。

当我想要从调度程序中删除一个任务时，问题就开始了。

是否有方法可以实现这一点？

使用一个调度程序处理不同的任务是否正确？如何最好地实现它？

- thepoosh

Answer 1

仅需取消由scheduledAtFixedRate()返回的未来任务：

// Create the scheduler
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
// Create the task to execute
Runnable r = new Runnable() {
    @Override
    public void run() {
        System.out.println("Hello");
    }
};
// Schedule the task such that it will be executed every second
ScheduledFuture<?> scheduledFuture =
    scheduledExecutorService.scheduleAtFixedRate(r, 1L, 1L, TimeUnit.SECONDS);
// Wait 5 seconds
Thread.sleep(5000L);
// Cancel the task
scheduledFuture.cancel(false);

需要注意的另一件事是，取消操作并不会将任务从调度程序中移除。它仅确保isDone方法始终返回true。如果您继续添加这样的任务，则可能会导致内存泄漏。例如：如果您基于某些客户端活动或UI按钮单击启动任务，重复n次并退出。如果该按钮被点击太多次，则可能会得到无法进行垃圾回收的大量线程池，因为调度程序仍然具有对其的引用。

您可能希望在Java 7及更高版本中提供的ScheduledThreadPoolExecutor类中使用setRemoveOnCancelPolicy(true)。出于向后兼容性考虑，默认值为false。

- JB Nizet

---

提示使用 newSingleThreadScheduledExecutor() 的人需要注意，因为它不公开内部执行器：请自己创建一个执行器，设置属性，然后使用 Executors.unconfigurableScheduledExecutorService() 进行封装。 - Mark Jeronimus

为什么我不能重复使用它？为什么很难删除已取消的任务？ - JohnyTex

要使用 setRemoveOnCancelPolicy(true)，请查看此处关于 ScheduledThreadPoolExecutor 实例化变量的解释：https://dev59.com/WloV5IYBdhLWcg3wEbS9#36748183。 - falvojr

Answer 2

如果你的ScheduledExecutorService实例继承了ThreadPoolExecutor(例如ScheduledThreadPoolExecutor)，你可以使用remove(Runnable)(但请查看其javadoc中的注释："它可能无法删除已被转换为其他形式并放置在内部队列中的任务。")或purge()。

- Gary

---

感谢您的回答，当时这个方法在“Executor”中不存在。 - thepoosh