ScheduledThreadPoolExecutor原理详解

た入场券 2023-01-07 10:12 176阅读 0赞

ScheduledThreadPoolExecutor是一个可以在指定一定延迟时间后或者定时进行任务调度执行的线程池。

ScheduledThreadPoolExecutor继承了ThreadPoolExecutor并实现了ScheduledExecutorService接口。线程池队列是DelayedWorkQueue，其和DelayedQueue类似，是一个延迟队列。

### 三个重要方法： ###

**schedule(Runnable command, long delay, TimeUnit unit)方法**

该方法的作用是提交一个延迟执行的任务，任务从提交时间算起延迟单位位unit的delay时间后开始执行。提交的任务不是周期性任务，任务只会执行一次。

**scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)方法**

该方法的作用是，当任务执行完毕后，让其延迟固定时间后再次运行（fixed-delay任务）。其中initialDelay表示提交任务后延迟多少时间开始执行任务command，delay表示当任务执行完毕后延长多少时间后再次运行command任务，unit是initialDelay和delay的时间单位。任务会一直重复运行直到任务中抛出了异常，被取消了，或者关闭了线程池。

**scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)方法**

该方法相对起始时间点以固定频率调用指定的任务（fixed-rate任务)。当把任务提交到线程池并延迟initialDelay时间后开始执行任务command。然后从initialDelay+period时间点再次执行，而后在initialDelay+2\*period时间点再次执行，循环往复，直到抛出异常或者调用了任务的cancel方法取消了任务，或者关闭了线程池。

相对于fixed-delay任务来说，fixed-rate方式执行规则为，时间为initdelday+n\*period时启动任务，但是如果当前任务还没有执行完，下一次执行任务的时间到了，则不会并发执行，下次要执行的任务会延迟执行，要等到当前任务执行完毕后在执行。

### 总结： ###

ScheduledThreadPoolExecutor内部使用DelayQueue来存放具体任务。任务分为三种，其中一次性执行任务执行完毕就结束了，fixed-delay任务保证同一个任务在多次执行之间间隔固定时间，fixed-rate任务保证按照固定的频率执行。任务类型使用period的值来区分。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpX3dfY2g_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpX3dfY2g_size_16_color_FFFFFF_t_70]: /images/20221119/e310c2919b2247db8c3b557ca5ef7f0d.png