摘要：每個通過網絡到達服務器的連接都被包裝成一個任務并且傳遞給線程池。線程池的線程會并發(fā)的處理連接上的請求。用線程池控制線程數量，其他線程排隊等候。實現包，線程池頂級接口是但是嚴格意義講并不是一個線程。此線程池支持定時以及周期性執(zhí)行任務的需求。

tutorial site1
tutorial site2

每啟動一個新線程都會有相應的性能開銷(涉及到OS的交互：創(chuàng)建線程，銷毀線程)，而且每個線程都需要給棧分配一些內存等等。這種代價隨著新線程不斷的創(chuàng)建，將會大大降低性能甚至使JVM崩潰。

如何解決？
使線程可以復用，執(zhí)行完一個任務，并不被銷毀，而是可以繼續(xù)執(zhí)行其他的任務。這樣避免了創(chuàng)建以及銷毀線程的代價以及線程過多造成內存消耗過度以及切換過度問題。

線程池（Thread Pool）的引入就是：限制應用程序中同一時刻運行的線程數。根據系統(tǒng)的環(huán)境，可以手動或者自動設置線程數量，達到最佳效果。

可以把并發(fā)執(zhí)行的任務傳遞給一個線程池，來替代為每個并發(fā)執(zhí)行的任務都啟動一個新的線程。只要池里有空閑的線程，任務就會分配給一個線程執(zhí)行。 在線程池的內部，任務被插入一個阻塞隊列(任務隊列), 線程池的線程會去取這個隊列的任務。當一個新任務插入隊列時，一個空閑線程就會成功的從隊列中取出任務并執(zhí)行它。

線程池經常應用在多線程服務器上。每個通過網絡到達服務器的連接都被包裝成一個任務并且傳遞給線程池。線程池的線程會并發(fā)的處理連接上的請求。Java 5 在 java.util.concurrent 包中自帶了內置的線程池，所以你不用非得實現自己的線程池。

線程池的作用：
合理利用線程池能夠帶來三個好處。
第一：降低資源消耗。通過重復利用已創(chuàng)建的線程降低線程創(chuàng)建和銷毀造成的消耗。
第二：提高響應速度。當任務到達時，任務可以不需要等到線程創(chuàng)建就能立即執(zhí)行。
第三：提高線程的可管理性。線程是稀缺資源，如果無限制的創(chuàng)建，不僅會消耗系統(tǒng)資源，還會降低系統(tǒng)的穩(wěn)定性，使用線程池可以進行統(tǒng)一的分配，調優(yōu)和監(jiān)控。但是要做到合理的利用線程池，必須對其原理了如指掌。

線程池實現了系統(tǒng)中線程的數量。
根據系統(tǒng)的環(huán)境情況，可以自動或手動設置線程數量，達到運行的最佳效果；少了浪費了系統(tǒng)資源，多了造成系統(tǒng)擁擠效率不高。用線程池控制線程數量，其他線程排隊等候。一個任務執(zhí)行完畢，再從隊列的中取最前面的任務開始執(zhí)行。若隊列中沒有等待進程，線程池的這一資源處于等待。當一個新任務需要運行時，如果線程池中有等待的工作線程，就可以開始運行了；否則進入等待隊列。

JUC 包，線程池頂級接口是Executor. 但是嚴格意義講Executor并不是一個線程。 而只是一個執(zhí)行線程的工具。真正的線程池的接口是ExecutorService.

要配置一個線程池是比較復雜的，尤其是對于線程池的原理不是很清楚的情況下，很有可能配置的線程池不是較優(yōu)的，因此在 Executors 類里面提供了一些靜態(tài)工廠，生成一些常用的線程池。
1. newSingleThreadExecutor()
創(chuàng)建一個單線程的線程池。這個線程池只有一個線程在工作，也就是相當于單線程串行執(zhí)行所有任務。如果這個唯一的線程因為異常結束，那么會有一個新的線程來替代它。此線程池保證所有任務的執(zhí)行順序按照任務的提交順序執(zhí)行。

javapublic classMyThread extends Thread {
    publicvoid run() {
        System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行。。。");
    }
}

public classTestSingleThreadExecutor {
    public static void main(String[] args) {
        // 創(chuàng)建一個可重用固定線程數的線程池
        ExecutorService pool = Executors.newSingleThreadExecutor();
        // 創(chuàng)建實現了 Runnable 接口對象，Thread 對象當然也實現了 Runnable 接口
        Thread t1 = new MyThread();
        Thread t2 = new MyThread();
        Thread t3 = new MyThread();
        Thread t4 = new MyThread();
        Thread t5 = new MyThread();
        // 將線程放入池中進行執(zhí)行
        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        // 關閉線程池
        pool.shutdown();
    }
}

javapublicclass TestFixedThreadPool {
    publicstaticvoid main(String[] args) {
        // 創(chuàng)建一個可重用固定線程數的線程池
        ExecutorService pool = Executors.newFixedThreadPool(2);
        // 創(chuàng)建實現了 Runnable 接口對象，Thread 對象當然也實現了 Runnable 接口
        Thread t1 = new MyThread();
        Thread t2 = new MyThread();
        Thread t3 = new MyThread();
        Thread t4 = new MyThread();
        Thread t5 = new MyThread();
        // 將線程放入池中進行執(zhí)行
        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        // 關閉線程池
        pool.shutdown();
    }
}

javapublicclass TestCachedThreadPool {
    publicstaticvoid main(String[] args) {
        // 創(chuàng)建一個可重用固定線程數的線程池
        ExecutorService pool = Executors.newCachedThreadPool();
        // 創(chuàng)建實現了 Runnable 接口對象，Thread 對象當然也實現了 Runnable 接口
        Thread t1 = new MyThread();
        Thread t2 = new MyThread();
        Thread t3 = new MyThread();
        Thread t4 = new MyThread();
        Thread t5 = new MyThread();
        // 將線程放入池中進行執(zhí)行
        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        // 關閉線程池
        pool.shutdown();
    }
}

javapublicclass TestScheduledThreadPoolExecutor {
    publicstaticvoid main(String[] args) {
        ScheduledThreadPoolExecutor exec = new ScheduledThreadPoolExecutor(1);
        exec.scheduleAtFixedRate(new Runnable() {// 每隔一段時間就觸發(fā)異常
                      @Override
                      publicvoid run() {
                           //throw new RuntimeException();
                           System.out.println("================");
                      }
                  }, 1000, 5000, TimeUnit.MILLISECONDS);
        exec.scheduleAtFixedRate(new Runnable() {// 每隔一段時間打印系統(tǒng)時間，證明兩者是互不影響的
                      @Override
                      publicvoid run() {
                           System.out.println(System.nanoTime());
                      }
                  }, 1000, 2000, TimeUnit.MILLISECONDS);
    }
}