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

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

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

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

Executors.newScheduledThreadPool(int);

當有重載方法，我們最常用的是這個就從這個，看下定義：

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

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

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

}

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

這就是我們需要思考的了，通過源碼考察，我們發(fā)現(xiàn)，他們都有execute方法，只是ScheduledThreadPoolExecutor將源碼進行了重寫，并且還有以下四個調(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);

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

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

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

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

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

public void execute(Runnable command) {

if (command == null)

throw new NullPointerException();

schedule(command, 0, TimeUnit.NANOSECONDS);

}

我們簡單看看scheduleAtFixedRate、scheduleWithFixedDelay對下面的分析會更加有用途：

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