如何从其他任务取消ScheduledFuture任务并优雅地结束？

2019-06-09 05:48:58 阅读：3676 来源： 互联网

标签：java multithreading java-8 scheduled-tasks scheduledexecutorservice

我正在使用ScheduledExecutorService.我想要做的是启动一个简单的自动收报机(每秒一个滴答)并安排另一个任务(5秒后)取消第一个任务.然后阻止主线程直到所有内容完成,这应该在两个任务完成后( – 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);

让我感到惊讶的问题是,BLOCKS好像还有一些正在运行的任务.为什么？ cancelTask应该立即结束并且scheduledTickTask刚刚被取消,那么问题是什么？

解决方法:

根据ExecutorService.awaitTermination的Javadoc(强调我的)：

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

这意味着你需要先调用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);

在您的情况下,超时将永远不会发生,因为您实际上将其设置为“无穷大”并且当前线程不会中断.

标签：java,multithreading,java-8,scheduled-tasks,scheduledexecutorservice
来源： https://codeday.me/bug/20190609/1203063.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

如何从其他任务取消ScheduledFuture任务并优雅地结束？