互聯(lián)網(wǎng)/程序員/技術(shù)/資料共享?
來自：cnblogs.com/aaron911/p/6213808.html
1. 為什么使用線程池
為每個請求對應(yīng)一個線程方法的不足是：為每個請求創(chuàng)建一個新線程的開銷很大；為每個請求創(chuàng)建新線程的服務(wù)器在創(chuàng)建和銷毀線程上花費(fèi)的時間和消耗的系統(tǒng)資源要比花在處理實(shí)際的用戶請求的時間和資源更多。容易引起資源不足，造成浪費(fèi)。為解決單個任務(wù)處理時間很短而請求的數(shù)目巨大的問題，引出線程池：通過對多個任務(wù)重用線程，線程創(chuàng)建的開銷被分?jǐn)偟搅硕鄠€任務(wù)上。其好處是，因?yàn)樵谡埱蟮竭_(dá)時線程已經(jīng)存在，所以無意中也消除了線程創(chuàng)建所帶來的延遲，使應(yīng)用程序響應(yīng)更快；通過適當(dāng)?shù)卣{(diào)整線程池中的線程數(shù)目，也就是當(dāng)請求的數(shù)目超過某個閾值時，就強(qiáng)制其它任何新到的請求一直等待，直到獲得一個線程來處理為止，從而可以防止資源不足。2. 使用線程池的風(fēng)險
雖然線程池是構(gòu)建多線程應(yīng)用程序的強(qiáng)大機(jī)制，但使用它并不是沒有風(fēng)險的。用線程池構(gòu)建的應(yīng)用程序容易遭受任何其它多線程應(yīng)用程序容易遭受的所有并發(fā)風(fēng)險，諸如同步錯誤和死鎖，它還容易遭受特定于線程池的少數(shù)其它風(fēng)險，諸如與池有關(guān)的死鎖、資源不足和線程泄漏。2.1 死鎖
任何多線程應(yīng)用程序都有死鎖風(fēng)險。當(dāng)一組進(jìn)程或線程中的每一個都在等待一個只有該組中另一個進(jìn)程才能引起的事件時，我們就說這組進(jìn)程或線程 死鎖了。死鎖的最簡單情形是：線程 A 持有對象 X 的獨(dú)占鎖，并且在等待對象 Y 的鎖，而線程 B 持有對象 Y 的獨(dú)占鎖，卻在等待對象 X 的鎖。除非有某種方法來打破對鎖的等待（Java 鎖定不支持這種方法），否則死鎖的線程將永遠(yuǎn)等下去。
雖然任何多線程程序中都有死鎖的風(fēng)險，但線程池卻引入了另一種死鎖可能，在那種情況下，所有池線程都在執(zhí)行已阻塞的等待隊(duì)列中另一任務(wù)的執(zhí)行結(jié)果的任務(wù)，但這一任務(wù)卻因?yàn)闆]有未被占用的線程而不能運(yùn)行。當(dāng)線程池被用來實(shí)現(xiàn)涉及許多交互對象的模擬，被模擬的對象可以相互發(fā)送查詢，這些查詢接下來作為排隊(duì)的任務(wù)執(zhí)行，查詢對象又同步等待著響應(yīng)時，會發(fā)生這種情況。2.2 資源不足
線程池的一個優(yōu)點(diǎn)在于：相對于其它替代調(diào)度機(jī)制（有些我們已經(jīng)討論過）而言，它們通常執(zhí)行得很好。但只有恰當(dāng)?shù)卣{(diào)整了線程池大小時才是這樣的。線程消耗包括內(nèi)存和其它系統(tǒng)資源在內(nèi)的大量資源。除了 Thread 對象所需的內(nèi)存之外，每個線程都需要兩個可能很大的執(zhí)行調(diào)用堆棧。除此以外，JVM 可能會為每個 Java 線程創(chuàng)建一個本機(jī)線程，這些本機(jī)線程將消耗額外的系統(tǒng)資源。最后，雖然線程之間切換的調(diào)度開銷很小，但如果有很多線程，環(huán)境切換也可能嚴(yán)重地影響程序的性能。如果線程池太大，那么被那些線程消耗的資源可能嚴(yán)重地影響系統(tǒng)性能。在線程之間進(jìn)行切換將會浪費(fèi)時間，而且使用超出比您實(shí)際需要的線程可能會引起資源匱乏問題，因?yàn)槌鼐€程正在消耗一些資源，而這些資源可能會被其它任務(wù)更有效地利用。除了線程自身所使用的資源以外，服務(wù)請求時所做的工作可能需要其它資源，例如 JDBC 連接、套接字或文件。這些也都是有限資源，有太多的并發(fā)請求也可能引起失效，例如不能分配 JDBC 連接。2.3?線程泄漏
各種類型的線程池中一個嚴(yán)重的風(fēng)險是線程泄漏，當(dāng)從池中除去一個線程以執(zhí)行一項(xiàng)任務(wù)，而在任務(wù)完成后該線程卻沒有返回池時，會發(fā)生這種情況。發(fā)生線程泄漏的一種情形出現(xiàn)在任務(wù)拋出一個 RuntimeException 或一個 Error 時。如果池類沒有捕捉到它們，那么線程只會退出而線程池的大小將會永久減少一個。當(dāng)這種情況發(fā)生的次數(shù)足夠多時，線程池最終就為空，而且系統(tǒng)將停止，因?yàn)闆]有可用的線程來處理任務(wù)。有些任務(wù)可能會永遠(yuǎn)等待某些資源或來自用戶的輸入，而這些資源又不能保證變得可用，用戶可能也已經(jīng)回家了，諸如此類的任務(wù)會永久停止，而這些停止的任務(wù)也會引起和線程泄漏同樣的問題。如果某個線程被這樣一個任務(wù)永久地消耗著，那么它實(shí)際上就被從池除去了。對于這樣的任務(wù)，應(yīng)該要么只給予它們自己的線程，要么只讓它們等待有限的時間。3. 有效使用線程池的準(zhǔn)則
不要對那些同步等待其它任務(wù)結(jié)果的任務(wù)排隊(duì)。這可能會導(dǎo)致上面所描述的那種形式的死鎖，在那種死鎖中，所有線程都被一些任務(wù)所占用，這些任務(wù)依次等待排隊(duì)任務(wù)的結(jié)果，而這些任務(wù)又無法執(zhí)行，因?yàn)樗械木€程都很忙。在為時間可能很長的操作使用合用的線程時要小心。如果程序必須等待諸如 I/O 完成這樣的某個資源，那么請指定最長的等待時間，以及隨后是失效還是將任務(wù)重新排隊(duì)以便稍后執(zhí)行。這樣做保證了：通過將某個線程釋放給某個可能成功完成的任務(wù)，從而將最終取得某些進(jìn)展。理解任務(wù)。要有效地調(diào)整線程池大小，您需要理解正在排隊(duì)的任務(wù)以及它們正在做什么。它們是 CPU 限制的（CPU-bound）嗎？它們是 I/O 限制的（I/O-bound）嗎？您的答案將影響您如何調(diào)整應(yīng)用程序。如果您有不同的任務(wù)類，這些類有著截然不同的特征，那么為不同任務(wù)類設(shè)置多個工作隊(duì)列可能會有意義，這樣可以相應(yīng)地調(diào)整每個池。4. 線程池的大小設(shè)置
調(diào)整線程池的大小基本上就是避免兩類錯誤：線程太少或線程太多。雖然線程池大小的設(shè)置受到很多因素影響，但是這里給出一個參考公式：最佳線程數(shù)目 = （（線程等待時間+線程CPU時間）/線程CPU時間 ）* CPU數(shù)目比如平均每個線程CPU運(yùn)行時間為0.5s，而線程等待時間（非CPU運(yùn)行時間，比如IO）為1.5s，CPU核心數(shù)為8，那么根據(jù)上面這個公式估算得到：((0.5+1.5)/0.5)*8=32。這個公式進(jìn)一步轉(zhuǎn)化為：最佳線程數(shù)目 = （線程等待時間與線程CPU時間之比 + 1）* CPU數(shù)目線程等待時間所占比例越高，需要越多線程。線程CPU時間所占比例越高，需要越少線程。5. 常用的幾種線程池
5.1 newCachedThreadPool
創(chuàng)建一個可緩存線程池，如果線程池長度超過處理需要，可靈活回收空閑線程，若無可回收，則新建線程。工作線程的創(chuàng)建數(shù)量幾乎沒有限制(其實(shí)也有限制的,數(shù)目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。
如果長時間沒有往線程池中提交任務(wù)，即如果工作線程空閑了指定的時間(默認(rèn)為1分鐘)，則該工作線程將自動終止。終止后，如果你又提交了新的任務(wù)，則線程池重新創(chuàng)建一個工作線程。
在使用CachedThreadPool時，一定要注意控制任務(wù)的數(shù)量，否則，由于大量線程同時運(yùn)行，很有會造成系統(tǒng)癱瘓。
package?test;
import?java.util.concurrent.ExecutorService;
import?java.util.concurrent.Executors;
public?class?ThreadPoolExecutorTest?{
?public?static?void?main(String[]?args)?{
??ExecutorService?cachedThreadPool?=?Executors.newCachedThreadPool();
??for?(int?i?=?0;?i?10;?i++)?{
???final?int?index?=?i;
???try?{
????Thread.sleep(index?*?1000);
???}?catch?(InterruptedException?e)?{
????e.printStackTrace();
???}
???cachedThreadPool.execute(new?Runnable()?{
????public?void?run()?{
?????System.out.println(index);
????}
???});
??}
?}
}
5.2 newFixedThreadPool
創(chuàng)建一個指定工作線程數(shù)量的線程池。每當(dāng)提交一個任務(wù)就創(chuàng)建一個工作線程，如果工作線程數(shù)量達(dá)到線程池初始的最大數(shù)，則將提交的任務(wù)存入到池隊(duì)列中。FixedThreadPool是一個典型且優(yōu)秀的線程池，它具有線程池提高程序效率和節(jié)省創(chuàng)建線程時所耗的開銷的優(yōu)點(diǎn)。但是，在線程池空閑時，即線程池中沒有可運(yùn)行任務(wù)時，它不會釋放工作線程，還會占用一定的系統(tǒng)資源。package?test;
import?java.util.concurrent.ExecutorService;
import?java.util.concurrent.Executors;
public?class?ThreadPoolExecutorTest?{
?public?static?void?main(String[]?args)?{
??ExecutorService?fixedThreadPool?=?Executors.newFixedThreadPool(3);
??for?(int?i?=?0;?i?10;?i++)?{
???final?int?index?=?i;
???fixedThreadPool.execute(new?Runnable()?{
????public?void?run()?{
?????try?{
??????System.out.println(index);
??????Thread.sleep(2000);
?????}?catch?(InterruptedException?e)?{
??????e.printStackTrace();
?????}
????}
???});
??}
?}
}
因?yàn)榫€程池大小為3，每個任務(wù)輸出index后sleep 2秒，所以每兩秒打印3個數(shù)字。定長線程池的大小最好根據(jù)系統(tǒng)資源進(jìn)行設(shè)置如Runtime.getRuntime().availableProcessors()。5.3 newSingleThreadExecutor
創(chuàng)建一個單線程化的Executor，即只創(chuàng)建唯一的工作者線程來執(zhí)行任務(wù)，它只會用唯一的工作線程來執(zhí)行任務(wù)，保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級)執(zhí)行。如果這個線程異常結(jié)束，會有另一個取代它，保證順序執(zhí)行。單工作線程最大的特點(diǎn)是可保證順序地執(zhí)行各個任務(wù)，并且在任意給定的時間不會有多個線程是活動的。package?test;
import?java.util.concurrent.ExecutorService;
import?java.util.concurrent.Executors;
public?class?ThreadPoolExecutorTest?{
?public?static?void?main(String[]?args)?{
??ExecutorService?singleThreadExecutor?=?Executors.newSingleThreadExecutor();
??for?(int?i?=?0;?i?10;?i++)?{
???final?int?index?=?i;
???singleThreadExecutor.execute(new?Runnable()?{
????public?void?run()?{
?????try?{
??????System.out.println(index);
??????Thread.sleep(2000);
?????}?catch?(InterruptedException?e)?{
??????e.printStackTrace();
?????}
????}
???});
??}
?}
}
5.4 newScheduleThreadPool
創(chuàng)建一個定長的線程池，而且支持定時的以及周期性的任務(wù)執(zhí)行，支持定時及周期性任務(wù)執(zhí)行。延遲3秒執(zhí)行，延遲執(zhí)行示例代碼如下：package?test;
import?java.util.concurrent.Executors;
import?java.util.concurrent.ScheduledExecutorService;
import?java.util.concurrent.TimeUnit;
public?class?ThreadPoolExecutorTest?{
?public?static?void?main(String[]?args)?{
??ScheduledExecutorService?scheduledThreadPool?=?Executors.newScheduledThreadPool(5);
??scheduledThreadPool.schedule(new?Runnable()?{
???public?void?run()?{
????System.out.println("delay?3?seconds");
???}
??},?3,?TimeUnit.SECONDS);
?}
}
表示延遲1秒后每3秒執(zhí)行一次，定期執(zhí)行示例代碼如下：package?test;
import?java.util.concurrent.Executors;
import?java.util.concurrent.ScheduledExecutorService;
import?java.util.concurrent.TimeUnit;
public?class?ThreadPoolExecutorTest?{
?public?static?void?main(String[]?args)?{
??ScheduledExecutorService?scheduledThreadPool?=?Executors.newScheduledThreadPool(5);
??scheduledThreadPool.scheduleAtFixedRate(new?Runnable()?{
???public?void?run()?{
????System.out.println("delay?1?seconds,?and?excute?every?3?seconds");
???}
??},?1,?3,?TimeUnit.SECONDS);
?}
}
推薦閱讀：
【70期】面試官：對并發(fā)熟悉嗎？談?wù)剬olatile的使用及其原理
【69期】面試官：對并發(fā)熟悉嗎？談?wù)劸€程間的協(xié)作(wait/notify/sleep/yield/join)
【68期】面試官：對并發(fā)熟悉嗎？說說Synchronized及實(shí)現(xiàn)原理
5T技術(shù)資源大放送！包括但不限于：C/C++，Linux，Python，Java，PHP，人工智能，單片機(jī)，樹莓派，等等。在公眾號內(nèi)回復(fù)「2048」，即可免費(fèi)獲取！！微信掃描二維碼，關(guān)注我的公眾號
朕已閱?
