摘要：在開發(fā)過程中，合理地使用線程池能夠帶來個(gè)好處。性質(zhì)不同的任務(wù)可以交給不同規(guī)模的線程池執(zhí)行。當(dāng)然具體合理線程池值大小，需要結(jié)合系統(tǒng)實(shí)際情況，在大量的嘗試下比較才能得出，以上只是前人總結(jié)的規(guī)律。

Java中的線程池是運(yùn)用場(chǎng)景最多的并發(fā)框架，幾乎所有需要異步或并發(fā)執(zhí)行任務(wù)的程序都可以使用線程池。在開發(fā)過程中，合理地使用線程池能夠帶來3個(gè)好處。

降低資源消耗。通過重復(fù)利用已創(chuàng)建的線程降低線程創(chuàng)建和銷毀造成的消耗

提高響應(yīng)速度。當(dāng)任務(wù)到達(dá)時(shí)，任務(wù)可以不需要等到線程創(chuàng)建就能立即執(zhí)行

提高線程的可管理性。線程是稀缺資源，如果無限制地創(chuàng)建，不僅會(huì)消耗系統(tǒng)資源，還會(huì)降低系統(tǒng)的穩(wěn)定性，使用線程池可以進(jìn)行統(tǒng)一分配、調(diào)優(yōu)和監(jiān)控

線程池是為突然大量爆發(fā)的線程設(shè)計(jì)的，通過有限的幾個(gè)固定線程為大量的操作服務(wù)，減少了創(chuàng)建和銷毀線程所需的時(shí)間，從而提高效率。
如果一個(gè)線程的時(shí)間非常長(zhǎng)，就沒必要用線程池了(不是不能作長(zhǎng)時(shí)間操作，而是不宜。)，況且我們還不能控制線程池中線程的開始、掛起、和中止

Executor框架的最頂層實(shí)現(xiàn)是ThreadPoolExecutor類，Executors工廠類中提供的newScheduledThreadPool、newFixedThreadPool、newCachedThreadPool方法其實(shí)也只是ThreadPoolExecutor的構(gòu)造函數(shù)參數(shù)不同而已。通過傳入不同的參數(shù)，就可以構(gòu)造出適用于不同應(yīng)用場(chǎng)景下的線程池
corePoolSize： 核心池的大小。 當(dāng)有任務(wù)來之后，就會(huì)創(chuàng)建一個(gè)線程去執(zhí)行任務(wù)，當(dāng)線程池中的線程數(shù)目達(dá)到corePoolSize后，就會(huì)把到達(dá)的任務(wù)放到緩存隊(duì)列當(dāng)中
maximumPoolSize： 線程池最大線程數(shù)，它表示在線程池中最多能創(chuàng)建多少個(gè)線程；
keepAliveTime： 表示線程沒有任務(wù)執(zhí)行時(shí)最多保持多久時(shí)間會(huì)終止。
unit： 參數(shù)keepAliveTime的時(shí)間單位，有7種取值

創(chuàng)建一個(gè)可緩存線程池，如果線程池長(zhǎng)度超過處理需要，可靈活回收空閑線程，若無可回收，則新建線程。
線程池為無限大，當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成，會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程，而不用每次新建線程

創(chuàng)建一個(gè)定長(zhǎng)線程池，可控制線程最大并發(fā)數(shù)，超出的線程會(huì)在隊(duì)列中等待
定長(zhǎng)線程池的大小最好根據(jù)系統(tǒng)資源進(jìn)行設(shè)置。如Runtime.getRuntime().availableProcessors()

創(chuàng)建一個(gè)定長(zhǎng)線程池，支持定時(shí)及周期性任務(wù)執(zhí)行

創(chuàng)建一個(gè)單線程化的線程池，它只會(huì)用唯一的工作線程來執(zhí)行任務(wù)，保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行

提交一個(gè)任務(wù)到線程池中，線程池的處理流程如下：
1、判斷線程池里的核心線程是否都在執(zhí)行任務(wù)，如果不是（核心線程空閑或者還有核心線程沒有被創(chuàng)建）則創(chuàng)建一個(gè)新的工作線程來執(zhí)行任務(wù)。如果核心線程都在執(zhí)行任務(wù)，則進(jìn)入下個(gè)流程。
2、線程池判斷工作隊(duì)列是否已滿，如果工作隊(duì)列沒有滿，則將新提交的任務(wù)存儲(chǔ)在這個(gè)工作隊(duì)列里。如果工作隊(duì)列滿了，則進(jìn)入下個(gè)流程。
3、判斷線程池里的線程是否都處于工作狀態(tài)，如果沒有，則創(chuàng)建一個(gè)新的工作線程來執(zhí)行任務(wù)。如果已經(jīng)滿了，則交給飽和策略來處理這個(gè)任務(wù)。

CPU密集

CPU密集的意思是該任務(wù)需要大量的運(yùn)算，而沒有阻塞，CPU一直全速運(yùn)行。
CPU密集任務(wù)只有在真正的多核CPU上才可能得到加速(通過多線程)，而在單核CPU上，無論你開幾個(gè)模擬的多線程，該任務(wù)都不可能得到加速，因?yàn)镃PU總的運(yùn)算能力就那些。

IO密集

IO密集型，即該任務(wù)需要大量的IO，即大量的阻塞。在單線程上運(yùn)行IO密集型的任務(wù)會(huì)導(dǎo)致浪費(fèi)大量的CPU運(yùn)算能力浪費(fèi)在等待。所以在IO密集型任務(wù)中使用多線程可以大大的加速程序運(yùn)行，即時(shí)在單核CPU上，這種加速主要就是利用了被浪費(fèi)掉的阻塞時(shí)間

要想合理的配置線程池的大小，首先得分析任務(wù)的特性，可以從以下幾個(gè)角度分析：

任務(wù)的性質(zhì)：CPU密集型任務(wù)、IO密集型任務(wù)、混合型任務(wù)。

任務(wù)的優(yōu)先級(jí)：高、中、低。

任務(wù)的執(zhí)行時(shí)間：長(zhǎng)、中、短。

任務(wù)的依賴性：是否依賴其他系統(tǒng)資源，如數(shù)據(jù)庫連接等。

性質(zhì)不同的任務(wù)可以交給不同規(guī)模的線程池執(zhí)行。
對(duì)于不同性質(zhì)的任務(wù)來說，CPU密集型任務(wù)應(yīng)配置盡可能小的線程，如配置CPU個(gè)數(shù)+1的線程數(shù)，IO密集型任務(wù)應(yīng)配置盡可能多的線程，因?yàn)镮O操作不占用CPU，不要讓CPU閑下來，應(yīng)加大線程數(shù)量，如配置兩倍CPU個(gè)數(shù)+1，而對(duì)于混合型的任務(wù)，如果可以拆分，拆分成IO密集型和CPU密集型分別處理，前提是兩者運(yùn)行的時(shí)間是差不多的，如果處理時(shí)間相差很大，則沒必要拆分了。
若任務(wù)對(duì)其他系統(tǒng)資源有依賴，如某個(gè)任務(wù)依賴數(shù)據(jù)庫的連接返回的結(jié)果，這時(shí)候等待的時(shí)間越長(zhǎng)，則CPU空閑的時(shí)間越長(zhǎng)，那么線程數(shù)量應(yīng)設(shè)置得越大，才能更好的利用CPU。
當(dāng)然具體合理線程池值大小，需要結(jié)合系統(tǒng)實(shí)際情況，在大量的嘗試下比較才能得出，以上只是前人總結(jié)的規(guī)律。

最佳線程數(shù)目 = （（線程等待時(shí)間+線程CPU時(shí)間）/線程CPU時(shí)間 ）* CPU數(shù)目
比如平均每個(gè)線程CPU運(yùn)行時(shí)間為0.5s，而線程等待時(shí)間（非CPU運(yùn)行時(shí)間，比如IO）為1.5s，CPU核心數(shù)為8，那么根據(jù)上面這個(gè)公式估算得到：((0.5+1.5)/0.5)*8=32。這個(gè)公式進(jìn)一步轉(zhuǎn)化為：
最佳線程數(shù)目 = （線程等待時(shí)間與線程CPU時(shí)間之比 + 1）* CPU數(shù)目
可以得出一個(gè)結(jié)論：
線程等待時(shí)間所占比例越高，需要越多線程。線程CPU時(shí)間所占比例越高，需要越少線程。
以上公式與之前的CPU和IO密集型任務(wù)設(shè)置線程數(shù)基本吻合。
CPU密集型時(shí)，任務(wù)可以少配置線程數(shù)，大概和機(jī)器的cpu核數(shù)相當(dāng)，這樣可以使得每個(gè)線程都在執(zhí)行任務(wù)
IO密集型時(shí)，大部分線程都阻塞，故需要多配置線程數(shù)，2*cpu核數(shù)
操作系統(tǒng)之名稱解釋：
某些進(jìn)程花費(fèi)了絕大多數(shù)時(shí)間在計(jì)算上，而其他則在等待I/O上花費(fèi)了大多是時(shí)間，
前者稱為計(jì)算密集型（CPU密集型）computer-bound，后者稱為I/O密集型，I/O-bound。

代碼

@RequestMapping("test-threadpool")
    public void testThreadPool() {
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1,
                6,
                60L,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(3));

        for (int i = 0; i < 6; i++) {
            TaskThred t1 = new TaskThred("任務(wù)" + i);
            threadPoolExecutor.execute(t1);
        }
        threadPoolExecutor.shutdown();
    }

class TaskThred implements Runnable {
    private String taskName;

    public TaskThred(String taskName) {
        this.taskName = taskName;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+taskName);
    }

}

結(jié)果

pool-1-thread-2任務(wù)4
pool-1-thread-1任務(wù)0
pool-1-thread-1任務(wù)1
pool-1-thread-1任務(wù)2
pool-1-thread-1任務(wù)3
pool-1-thread-3任務(wù)5