并发编程(十三)定时任务线程池使用与原理

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

# 线程池 

评论

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×