假定1個服務(wù)器完成1項(xiàng)任務(wù)所需時間為：T1 創(chuàng)建線程時間，T2 在線程中履行任務(wù)的時間，T3 燒毀線程時間。當(dāng)T1 + T3 遠(yuǎn)大于 T2時，采取多線程技術(shù)可以顯著減少處理器單元的閑置時間，增加處理器單元的吞吐能力。

    線程池就是1個線程的容器，每次只履行額定數(shù)量的線程， 線程池作用就是限制系統(tǒng)中履行線程的數(shù)量。采取線程池不但調(diào)劑T1,T3產(chǎn)生的時間段，而且它還顯著減少了創(chuàng)建線程的數(shù)目。

    為何要用線程池:

    1）減少了創(chuàng)建和燒毀線程的次數(shù)，每一個工作線程都可以被重復(fù)利用，可履行多個任務(wù)

    2）可以根據(jù)系統(tǒng)的承受能力，調(diào)劑線程池中工作線線程的數(shù)目，避免由于由于消耗過量的內(nèi)存，而把服務(wù)器累趴下(每一個線程需要大約1MB內(nèi)存，線程開的越多，消耗的內(nèi)存也就越大，最后死機(jī))

      Java1.5以后，Java 提供了自己的線程池ThreadPoolExecutor類。

ThreadPoolExecutor使用簡介

線程池類為java.util.concurrent.ThreadPoolExecutor，經(jīng)常使用構(gòu)造方法為：

public ThreadPoolExecutor(  

            int corePoolSize,  

            int maximumPoolSize,  

            long keepAliveTime,  

            TimeUnit unit,  

            BlockingQueue<Runnable> workQueue) 

corePoolSize 指的是保存的線程池大小。

maximumPoolSize 指的是線程池的最大大小。

keepAliveTime 指的是空閑線程結(jié)束的超時時間。

unit 是1個枚舉，表示 keepAliveTime 的單位。

workQueue 表示寄存任務(wù)的隊(duì)列。

    1個任務(wù)通過 execute(Runnable)方法被添加到線程池，任務(wù)就是1個 Runnable類型的對象，任務(wù)的履行方法就是 Runnable類型對象的run()方法。

線程池的工作進(jìn)程以下：

1、線程池剛創(chuàng)建時，里面沒有1個線程。任務(wù)隊(duì)列是作為參數(shù)傳進(jìn)來的。不過，就算隊(duì)列里面有任務(wù)，線程池也不會馬上履行它們。

2、當(dāng)調(diào)用 execute() 方法添加1個任務(wù)時，線程池會做以下判斷：

    a. 如果正在運(yùn)行的線程數(shù)量小于 corePoolSize，那末馬上創(chuàng)建線程運(yùn)行這個任務(wù)；

    b. 如果正在運(yùn)行的線程數(shù)量大于或等于corePoolSize，那末將這個任務(wù)放入隊(duì)列。

    c. 如果這時候候隊(duì)列滿了，而且正在運(yùn)行的線程數(shù)量小于 maximumPoolSize，那末還是要創(chuàng)建線程運(yùn)行這個任務(wù)；

    d. 如果隊(duì)列滿了，而且正在運(yùn)行的線程數(shù)量大于或等于 maximumPoolSize，那末線程池會拋出異常，告知調(diào)用者“我不能再接受任務(wù)了”。

3、當(dāng)1個線程完成任務(wù)時，它會從隊(duì)列中取下1個任務(wù)來履行。

4、當(dāng)1個線程無事可做，超過1定的時間（keepAliveTime）時，線程池會判斷，如果當(dāng)前運(yùn)行的線程數(shù)大于 corePoolSize，那末這個線程就被停掉。所以線程池的所有任務(wù)完成后，它終究會收縮到 corePoolSize 的大小。

   這樣的進(jìn)程說明，其實(shí)不是先加入任務(wù)就1定會先履行。假定隊(duì)列大小為10，corePoolSize為3，maximumPoolSize 為6，那末當(dāng)加入 20 個任務(wù)時，履行的順序就是這樣的：首先履行任務(wù) 1、2、3，然后任務(wù)4~13被放入隊(duì)列。這時候候隊(duì)列滿了，任務(wù) 14、15、16 會被馬上履行，而任務(wù) 17~20 則會拋出異常。終究順序是：1、2、3、14、15、16、4、5、6、7、8、9、10、11、12、13。

下面是1個線程池使用的例子：

public class TestThreadPool {  

    public static void main(String[] args) {  

        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(3, 6, 5,TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());  

         for (int i = 1; i <= 20; i++) {   

             threadPool.execute(new ThreadPoolTask());  

             //threadPool.shutdown();  
        }  
    }  
}
 

創(chuàng)建 ThreadPoolTask類：

public class ThreadPoolTask implements Runnable {  
    public void run() {  
        try {  
            System.out.println("開始履行任務(wù)：" + attachData);       
            Thread.sleep(100);  
        }
        catch(Exception e){  
            e.printStackTrace();  
        }  
    }  
}

1、BlockingQueue 只是1個接口，經(jīng)常使用的實(shí)現(xiàn)類有 LinkedBlockingQueue 和 ArrayBlockingQueue。用 LinkedBlockingQueue 的好處在于沒有大小限制。這樣的話，由于隊(duì)列不會滿，所以 execute() 不會拋出異常，而線程池中運(yùn)行的線程數(shù)也永久不會超過 corePoolSize 個，keepAliveTime 參數(shù)也就沒成心義了。

2、shutdown() 方法不會阻塞。調(diào)用 shutdown() 方法以后，主線程就馬上結(jié)束了，而線程池會繼續(xù)運(yùn)行直到所有任務(wù)履行完才會停止。如果不調(diào)用 shutdown() 方法，那末線程池會1直保持下去，以便隨時添加新的任務(wù)。