快捷導(dǎo)航

搞懂Java線程池

更新時(shí)間：2019年04月22日 12:01:00 作者：yes的練級(jí)手冊(cè)

這篇文章主要介紹了Java線程池，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

身為程序員我們對(duì)線程是再熟悉不過了，多線程并發(fā)算是Java進(jìn)階的知識(shí)，用好多線程不容易有太多的坑。創(chuàng)建線程也算是一個(gè)"重"操作。創(chuàng)建線程的語句是new Thread()咋一看好像就是new了一個(gè)對(duì)象。

沒錯(cuò)是new了個(gè)對(duì)象，但是不僅僅是普通對(duì)象那樣在堆中分配了一塊內(nèi)存，它還需要調(diào)用操作系統(tǒng)內(nèi)核API，然后操作系統(tǒng)再為線程分配一些資源。所以較普通對(duì)象，線程就比較“重了”。所以我們要避免頻繁的創(chuàng)建和銷毀線程，還得控制一下線程的數(shù)量。線程池就是用來完成這一項(xiàng)使命的。

所以多線程就離不開線程池，所以要掌握多線程編程，線程池的了解必不可少。

線程池的設(shè)計(jì)就是采用生產(chǎn)者-消費(fèi)者模式，線程池里面的線程是消費(fèi)者，我們?nèi)o線程池的任務(wù)是生產(chǎn)者?？梢岳斫獬删€程池就是火車站售票廳，線程池里面的線程就是火車站售票廳窗口員工，我們?nèi)ベI票或者退票改簽就是給窗口員工任務(wù)也就是生產(chǎn)，然后窗口員工幫我們辦理業(yè)務(wù)，也就是消費(fèi)。

一般我們是用ThreadPoolExecutor來創(chuàng)建線程池，我找了里面參數(shù)最多的構(gòu)造器。

1、corePoolSize

按字面翻譯過來就是核心池大小，其實(shí)就是線程池保有的最小的線程數(shù)，這里需要注意一下，初始化線程池的時(shí)候，除非調(diào)用prestartAllCoreThreads或者prestartCoreThread這兩個(gè)方法，這兩個(gè)方法分別是在無任務(wù)到來之前預(yù)創(chuàng)建所有核心線程或者創(chuàng)建一個(gè)線程。否則線程池初始化后沒任務(wù)進(jìn)來前是沒有線程的。只有當(dāng)任務(wù)來了才會(huì)創(chuàng)建線程。

所以這里保有的核心數(shù)指的是，當(dāng)線程池創(chuàng)建了這么多的線程之后，會(huì)保留的不會(huì)被回收的線程數(shù)，超過corePoolSize的線程在一定時(shí)間之后就會(huì)被回收。

但是java1.6新增了一個(gè)allowCoreThreadTimeOut(boolean value)方法，當(dāng)設(shè)為true時(shí)候，所有的線程都會(huì)超時(shí)回收，包括核心線程。

2、maximumPoolSize

最大線程數(shù)，也就是池里面能有的最大的線程數(shù)量。也就是火車站售票廳窗口所有的窗口都有員工在服務(wù)。特別是在節(jié)假日的時(shí)候，基本上窗口都會(huì)開放。

3、keepAliveTime、TimeUnit

keepAliveTime就是存活時(shí)間，TimeUnit是時(shí)間單位，來表明keepAliveTime的數(shù)字是秒啊還是毫秒啊等等。

這兩個(gè)參數(shù)就是當(dāng)我們線程池存在的線程數(shù)量超過corePoolSize時(shí)，如果有個(gè)線程已經(jīng)空閑了keepAliveTime這么長(zhǎng)的時(shí)間，那么這個(gè)空閑線程就要被回收了，就類似于出行高峰期過去了，售票廳窗口可以關(guān)閉幾個(gè)了。總不能都沒人了還開這么多窗口把，浪費(fèi)呀。

4、workQueue

工作隊(duì)列，是阻塞隊(duì)列。隊(duì)列存儲(chǔ)的也就是線程需要執(zhí)行的Runnable,也就是任務(wù)。對(duì)應(yīng)著就是去售票廳排隊(duì)的我們。

5、threadFactory

按名字翻譯過來就是線程工廠了，也就是我們可以搞個(gè)工廠，然后自定義如何創(chuàng)建線程，比如給線程set下名字啊等。然后線程池就會(huì)按照工廠定義的方式創(chuàng)建線程。就是如果不設(shè)定線程的名字的話，線程名可能就是什么thread-1這樣的，對(duì)于我們排查問題不太方便，所以給個(gè)名字來標(biāo)識(shí)一下比較好。

6、handler

這個(gè)是拒絕策略，也就是當(dāng)線程池中所有的線程都在執(zhí)行任務(wù)，并且工作隊(duì)列(是有界隊(duì)列)也排滿了，那再有任務(wù)提交就會(huì)執(zhí)行拒絕策略。ThreadPoolExecutor提供了四種拒絕策略

1、ThreadPoolExecutor.AbortPolicy()
是默認(rèn)的拒絕策略，會(huì)拋出 RejectedExcecutionException。
2、ThreadPoolExecutor.CallerRunsPolicy()
讓提交任務(wù)的線程自己去執(zhí)行這個(gè)任務(wù)。。好像這樣做挺有道理的..我沒空你自己搞去
3、ThreadPoolExecutor.DiscardOldestPolicy()
丟棄最老的任務(wù)，也就是工作隊(duì)列里最前面的任務(wù)，丟棄了之后把新任務(wù)加入到工作隊(duì)列中...真的不公平啊
4、ThreadPoolExecutor.DiscardPolicy()
直接丟棄任務(wù)，并且不拋出任何異常...假裝沒看到系列

除了這四種還可以自定義拒絕策略，建議自定義拒絕策略。因?yàn)楦拥挠押?，可以設(shè)置成服務(wù)降級(jí)啊等操作。

注意

Java并發(fā)包還提供了Executors,可以快速創(chuàng)建線程池，但是不推薦使用Executors。因?yàn)镋xecutors創(chuàng)建線程池都是默認(rèn)使用無界隊(duì)列LinkedBlockingQueue，在高負(fù)載的情況下容易OOM。所以建議使用有界隊(duì)列。