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

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

    為何要用線程池:

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

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

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

ThreadPoolExecutor使用簡(jiǎn)介

線程池類為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é)束的超時(shí)時(shí)間。

unit 是1個(gè)枚舉，表示 keepAliveTime 的單位。

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

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

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

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

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

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

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

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

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

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

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

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

下面是1個(gè)線程池使用的例子：

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

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