ScheduledThreadPoolExecutor使用

int initialDelay = 5;
        System.out.println(Thread.currentThread().getName() + " " + TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis()));
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
        //以上一个任务开始的时间计时，period时间过去后，检测上一个任务是否执行完毕，如果上一个任务执行完毕，则当前任务立即执行，如果上一个任务没有执行完毕，则需要等上一个任务执行完毕后立即执行。
        executorService.scheduleAtFixedRate(()->{
            System.out.println(Thread.currentThread().getName() + " " + TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis()));
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },initialDelay,5, TimeUnit.SECONDS);

        //以上一个任务结束时开始计时，period时间过去后，立即执行
        executorService.scheduleWithFixedDelay(()->{
            System.out.println(TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis()));
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },initialDelay,5, TimeUnit.SECONDS);

ScheduledThreadPoolExecutor原理

ScheduledThreadPoolExecutor 底层实现为ThreadPoolExecutor 和自定义 DelayWorkQueue延时队列结合使用，ThreadPoolExecutor 原理已在前面线程池原理与源码剖析中有详细说明，延时队列原理在Queue阻塞队列中详细说明。

大概原理：将任务封装到一个既实现Runnable接口又继承Delayed类的ScheduledFutureTask类中，放入延时队列中，再调用我们的ThreadPoolExecutor 中的executor方法开启线程，调用ScheduledFutureTask中的run方法，该方法再调用真正任务的run方法，处理完真正任务的run方法后，计算下次任务的执行时间，再次将ScheduledFutureTask放入延时队列，回到调用我们的ThreadPoolExecutor 中的executor方法的逻辑，继续往下执行。

定时任务线程池类关系.png

ScheduledFutureTask.png