005-五、Java并发 ScheduledThreadPoolExecutor
范例 1
ScheduledThreadPoolExecutor
扩展自 一文秒懂 Java
线程池之 ThreadPoolExecutor
讲解的 了ThreadPoolExecutor
类,并且添加了其它方法实现了 ScheduledExecutorService
接口。
schedule()
方法允许在指定的延迟后执行一次任务scheduleAtFixedRate()
方法允许在指定的初始延迟后执行任务,然后以一定的周期重复执行,其中period
参数用于指定两个任务的开始时间之间的间隔时间,因此任务执行的频率是固定的。scheduleWithFixedDelay()
方法类似于scheduleAtFixedRate()
,它也重复执行给定的任务,但period
参数用于指定前一个任务的结束和下一个任务的开始之间的间隔时间。也就是指定下一个任务延时多久后才执行。执行频率可能会有所不同,具体取决于执行任何给定任务所需的时间。
静态方法 Executors.newScheduledThreadPool()
方法用于创建包含了指定 corePoolSize
,无上限 maximumPoolSize
和 0
存活时间 keepAliveTime
的 ScheduledThreadPoolExecutor
实例。
例如下面的示例创建了一个包含了 5
个核心线程的 ScheduledThreadPoolExecutor
实例,且每隔 500
毫秒运行一个输出 Hello World
的任务
ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);
executor.schedule(() -> {
System.out.println("Hello World");
}, 500, TimeUnit.MILLISECONDS);
范例 2
下面的代码则演示了如何在 500
毫秒延迟后执行任务,然后每 100
毫秒重复执行一次。
CountDownLatch lock = new CountDownLatch(3);
ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);
ScheduledFuture<?> future = executor.scheduleAtFixedRate(() -> {
System.out.println("Hello World");
lock.countDown();
}, 500, 100, TimeUnit.MILLISECONDS);
lock.await(1000, TimeUnit.MILLISECONDS);
future.cancel(true);
写完了如果写得有什么问题,希望读者能够给小编留言,也可以点击[此处扫下面二维码关注微信公众号](https://www.ycbbs.vip/?p=28 "此处扫下面二维码关注微信公众号")
看完两件小事
如果你觉得这篇文章对你挺有启发,我想请你帮我两个小忙:
- 把这篇文章分享给你的朋友 / 交流群,让更多的人看到,一起进步,一起成长!
- 关注公众号 「方志朋」,公众号后台回复「666」 免费领取我精心整理的进阶资源教程
本文著作权归作者所有,如若转载,请注明出处
转载请注明:文章转载自「 Java极客技术学习 」https://www.javajike.com