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

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

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

首先如果我們要創建一個基于java本身的調度池通常的方法是：

Executors.newScheduledThreadPool(int);

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

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

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

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

}

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

這就是我們需要思考的了，通過源碼考察，我們發現，他們都有execute方法，只是ScheduledThreadPoolExecutor將源碼進行了重寫，并且還有以下四個調度器的方法：

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);

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

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

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

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

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

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