【工具类】ScheduledExecutorService 定期线程执行池的使用讲解

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);
上一篇:redis集群配置


下一篇:【ACWing】41. 包含min函数的栈