JAVA并发-ScheduledExecutorService

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 的工厂方法创建ScheduledExecutorService 实例,下面是代码:
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


推荐阅读