摘要：在前面介紹了的多線(xiàn)程的基本原理信息線(xiàn)程池架構(gòu)原理和源碼解析，本文對(duì)這個(gè)本身的線(xiàn)程池的調(diào)度器做一個(gè)簡(jiǎn)單擴(kuò)展，如果還沒(méi)讀過(guò)上一篇文章，建議讀一下，因?yàn)檫@是調(diào)度器的核心組件部分。

在前面介紹了java的多線(xiàn)程的基本原理信息：《Java線(xiàn)程池架構(gòu)原理和源碼解析》，本文對(duì)這個(gè)java本身的線(xiàn)程池的調(diào)度器做一個(gè)簡(jiǎn)單擴(kuò)展，如果還沒(méi)讀過(guò)上一篇文章，建議讀一下，因?yàn)檫@是調(diào)度器的核心組件部分。

我們?nèi)绻胘ava默認(rèn)的線(xiàn)程池來(lái)做調(diào)度器，一種選擇就是Timer和TimerTask的結(jié)合，在以前的文章：《Timer與TimerTask的真正原理&使用介紹》中有明確的說(shuō)明：一個(gè)Timer為一個(gè)多帶帶的線(xiàn)程，雖然一個(gè)Timer可以調(diào)度多個(gè)TimerTask，但是對(duì)于一個(gè)Timer來(lái)講是串行的，至于細(xì)節(jié)請(qǐng)參看對(duì)應(yīng)的那篇文章的內(nèi)容，本文介紹的多線(xiàn)程調(diào)度器，也就是定時(shí)任務(wù)，基于多線(xiàn)程調(diào)度完成，當(dāng)然你可以為了完成多線(xiàn)程使用多個(gè)Timer，只是這些Timer的管理需要你來(lái)完成，不是一個(gè)框架體系，而ScheduleThreadPoolExecutor提供了這個(gè)功能，所以我們第一要搞清楚是如何使用調(diào)度器的，其次是需要知道它的內(nèi)部原理是什么，也就是知其然，再知其所以然！

首先如果我們要?jiǎng)?chuàng)建一個(gè)基于java本身的調(diào)度池通常的方法是：

Executors.newScheduledThreadPool(int);

當(dāng)有重載方法，我們最常用的是這個(gè)就從這個(gè)，看下定義：

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
    return new ScheduledThreadPoolExecutor(corePoolSize);
}

其實(shí)內(nèi)部是new了一個(gè)實(shí)例化對(duì)象出來(lái)，并傳入大小，此時(shí)就跟蹤到ScheduledThreadPoolExecutor的構(gòu)造方法中：

public ScheduledThreadPoolExecutor(int corePoolSize) {
        super(corePoolSize, Integer.MAX_VALUE, 0,TimeUnit.NANOSECONDS,
              new DelayedWorkQueue());

}

你會(huì)發(fā)現(xiàn)調(diào)用了super，而super你跟蹤進(jìn)去會(huì)發(fā)現(xiàn)，是ThreadPoolExecutor中，那么ScheduledThreadPoolExecutor和ThreadPoolExecutor有何區(qū)別，就是本文要說(shuō)得重點(diǎn)了，首先我們留下個(gè)引子，你發(fā)現(xiàn)在定義隊(duì)列的時(shí)候，不再是上文中提到的LinkedBlockingQueue，而是DelayedWorkQueue，那么細(xì)節(jié)上我們接下來(lái)就是要講解的重點(diǎn)，既然他們又繼承關(guān)系，其實(shí)搞懂了不同點(diǎn)，就搞懂了共同點(diǎn)，而且有這樣的關(guān)系大多數(shù)應(yīng)當(dāng)是共同點(diǎn)，不同點(diǎn)的猜測(cè)：這個(gè)是要實(shí)現(xiàn)任務(wù)調(diào)度，任務(wù)調(diào)度不是立即的，需要延遲和定期做等情況，那么是如何實(shí)現(xiàn)的呢？

這就是我們需要思考的了，通過(guò)源碼考察，我們發(fā)現(xiàn)，他們都有execute方法，只是ScheduledThreadPoolExecutor將源碼進(jìn)行了重寫(xiě)，并且還有以下四個(gè)調(diào)度器的方法：

public ScheduledFuture schedule(Runnable command,
                       long delay, TimeUnit unit);

public  ScheduledFuture schedule(Callable callable,
                       long delay, TimeUnit unit);

public ScheduledFuture scheduleAtFixedRate(Runnable command,
                          long initialDelay,
                          long period,
                          TimeUnit unit);

public ScheduledFuture scheduleWithFixedDelay(Runnable command,
                             long initialDelay,
                             long delay,
                             TimeUnit unit);

那么這四個(gè)方法有什么區(qū)別呢？其實(shí)第一個(gè)和第二個(gè)區(qū)別不大，一個(gè)是Runnable、一個(gè)是Callable，內(nèi)部包裝后是一樣的效果；所以把頭兩個(gè)方法幾乎當(dāng)成一種調(diào)度，那么三種情況分別是：

1、 進(jìn)行一次延遲調(diào)度：延遲delay這么長(zhǎng)時(shí)間，單位為：TimeUnit傳入的的一個(gè)基本單位，例如：TimeUnit.SECONDS屬于提供好的枚舉信息；（適合于方法1和方法2）。

2、 多次調(diào)度，每次依照上一次預(yù)計(jì)調(diào)度時(shí)間進(jìn)行調(diào)度，例如：延遲2s開(kāi)始，5s一次，那么就是2、7、12、17，如果中間由于某種原因?qū)е戮€(xiàn)程不夠用，沒(méi)有得到調(diào)度機(jī)會(huì)，那么接下來(lái)計(jì)算的時(shí)間會(huì)優(yōu)先計(jì)算進(jìn)去，因?yàn)樗呐判驎?huì)被排在前面，有點(diǎn)類(lèi)似Timer中的：scheduleAtFixedRate方法，只是這里是多線(xiàn)程的，它的方法名也叫：scheduleAtFixedRate，所以這個(gè)是比較好記憶的（適合方法3）

3、 多次調(diào)度，每次按照上一次實(shí)際執(zhí)行的時(shí)間進(jìn)行計(jì)算下一次時(shí)間，同上，如果在第7秒沒(méi)有被得到調(diào)度，而是第9s才得到調(diào)度，那么計(jì)算下一次調(diào)度時(shí)間就不是12秒，而是9+5=14s，如果再次延遲，就會(huì)延遲一個(gè)周期以上，也就會(huì)出現(xiàn)少調(diào)用的情況（適合于方法3）；

4、 最后補(bǔ)充execute方法是一次調(diào)度，期望被立即調(diào)度，時(shí)間為空：

public void execute(Runnable command) {

if (command == null)

throw new NullPointerException();

schedule(command, 0, TimeUnit.NANOSECONDS);

}

我們簡(jiǎn)單看看scheduleAtFixedRate、scheduleWithFixedDelay對(duì)下面的分析會(huì)更加有用途：

public ScheduledFuture scheduleAtFixedRate(Runnable command,
                                                  long initialDelay,
                                                  long period,
                                                  TimeUnit unit) {
        if (command == null || unit == null)
            throw new NullPointerException();
        if (period <= 0)
            throw new IllegalArgumentException();
        RunnableScheduledFuture t = decorateTask(command,
            new ScheduledFutureTask