JAVA.util.concurrent.ScheduledExecutorService是一个可以安排任务延迟执行的 ExecutorService , 或者以固定的时间间隔重复执行 。任务通过一个工作线程异步执行,而不是提交任务到ScheduledExecutorService的线程 。
ScheduledExecutorService例子下面是ScheduledExecutorService例子:
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5); ScheduledFuture scheduledFuture = scheduledExecutorService.schedule(new Callable() { public Object call() throws Exception { System.out.println("Executed!"); return "Called!"; } }, 5, TimeUnit.SECONDS);
首先,创建一个容纳5个线程的.然后,创建了Callable 接口的一个匿名类作为参数提交到Callable 。
ScheduledExecutorService实现既然ScheduledExecutorService是个接口, ava.util.concurrent包中的ScheduledExecutorService 的类实现了该接口:
- ScheduledThreadPoolExecutor
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);
ScheduledExecutorService用法一旦创建了 ScheduledExecutorService,可以用下面方法 :- schedule (Callable task, long delay, TimeUnit timeunit)
- schedule (Runnable task, long delay, TimeUnit timeunit)
- scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit)
- scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit)
schedule (Callable task, long delay, TimeUnit timeunit)这个方法安排给定得 Callable 延迟执行,这方法返回ScheduledFuture,可以用于在任务未执行前取消任务或者当执行完了获取返回结果,下面是代码:
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5); ScheduledFuture scheduledFuture = scheduledExecutorService.schedule(new Callable() { public Object call() throws Exception { System.out.println("Executed!"); return "Called!"; } }, 5, TimeUnit.SECONDS); System.out.println("result = " + scheduledFuture.get()); scheduledExecutorService.shutdown();
输出结果:Executed!result = Called!
schedule (Runnable task, long delay, TimeUnit timeunit)这个方法类似于上面得方法,但是没有返回结果,所以任务完成 ScheduledFuture.get()将返回null 。scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit)这个方法安排任务间隔执行,任务首次在initialDelay以后执行,然后每次间隔initialDelay执行 。如果任何一次抛异常,那么任务不再执行,如果没有异常,任务一直执行直到ScheduledExecutorService 关闭,如果当前线程执行时间很长,那么下一个任务要等到这个任务执行完成,在同一时间只执行一个任务 。
scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit)这个方法和 scheduleAtFixedRate()非常相似,只是时间段有不同的解释 。
在scheduleAtFixedRate()方法中,周期被解释为从上一次执行开始到下一次执行开始之间的延迟 。
然而,在这种方法中,周期被解释为上一次执行结束到下一次执行开始之间的延迟 。因此,延迟是在完成执行之间,而不是在执行开始之间 。
ScheduledExecutorService Shutdown和 ExecutorService一样, 当任务执行完毕 ScheduledExecutorService需要关闭,如果不关闭,一直在JVM中运行,尽管其他线程已经关闭 。
关闭ScheduledExecutorService用shutdown() 或者 shutdownNow() 方法,这两个方法是从ExecutorService接口继承得,可以查看前面文章 ExecutorService 中得Shutdown。
参考:https://blog.csdn.net/cgsyck/article/details/107692471
http://tutorials.jenkov.com/java-util-concurrent/scheduledexecutorservice.html
【JAVA并发-ScheduledExecutorService】https://blog.csdn.net/cgsyck/article/details/107769550
推荐阅读
- JavaScript的深拷贝实现
- JAVA 开发工具Jcreator使用技巧总结
- 高并发的前后端的一般处理
- RabbitMq七种工作模式,结合简单的java实例使用,别再说你不会
- JavaScript九大面试问题集锦,助你顺利通关
- 自己总结 给初中级JAVA准备的面试题,致竞争激烈的秋招面试
- JavaScript黑科技:实现一个AST解释器
- 高并发来了如何处理,漏桶算法和令牌桶算法了解一下
- 详解Java面向对象开发,给你不一样的体验
- 迎难而上ArrayList,源码分析走一波