ScheduledExecutorService是一个可以用来定期执行线程任务的线程池,主要功能体现在,周期性执行线程任务和延迟时间来执行线程任务。主要特性体现在下面要讲解的四个方法中
方法一,延迟执行任务,不获取返回值
- 在指定delay(延迟)之后,执行提交Runnable的任务,返回一个ScheduledFuture
- 任务执行完成后,ScheduleFuture的get方法返回null,ScheduledFuture的作用是可以cancel任务
ScheduledExecutorService service = Executors.newScheduledThreadPool(8);
service.schedule(()-> System.out.println("五秒后输出"),5, TimeUnit.SECONDS);
方法二,延迟执行任务,获取返回值
- 在指定delay延迟之后,执行提交的Callable任务,返回一个ScheduleFuture获取任务的返回值
ScheduledExecutorService service = Executors.newScheduledThreadPool(8);
Callable<String> callable = () -> { TimeUnit.SECONDS.sleep(5);return "高级结果"; };
ScheduledFuture strFuture = service.schedule(callable,5,TimeUnit.SECONDS);
System.out.println("十秒后输出结果");
System.out.println(strFuture.get());
service.shutdown();
方法三,延迟执行任务,并固定利率性周期性执行任务。
- 提交一个Runnable任务,第一次回延迟initialDelay时间后,执行一次,此后会按照preiod的时间进行周期性执行
- 如果执行到某个方法使用的时间大于其周期时间,后面的任务会延后执行,直到上一个任务执行完成之后才会进行下一次执行。而不会并发执行。
- 如果在执行中遇到异常或者外部取消任务或者关闭任务了,任务也会退出。
service.scheduleAtFixedRate(()-> {
nums++;
if (nums==3){
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
if (nums==5){
service.shutdown();
}
System.out.println(printTime()+":周期性执行");
},2,2,TimeUnit.SECONDS);
方法四,延迟执行任务,并固定延迟周期性执行任务。
- 提交一个Runnable任务,第一次回延迟initialDelay时间后,执行一次,此后会按照preiod的时间进行周期性执行
- 如果其中有个任务执行时间操作周期时间,则这个任务执行完毕后,后面的任务会继续按周期时间进行延迟执行。
- 如果在执行中遇到异常或者外部取消任务或者关闭任务了,任务也会退出。
service.scheduleWithFixedDelay(()-> {
nums++;
if (nums==3){
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
if (nums==5){
service.shutdown();
}
System.out.println(printTime()+":周期性执行");
},2,2,TimeUnit.SECONDS);