- 線程池用過哪些鸥拧?線程池有哪些參數(shù)瘤旨?這幾個常用線程池的用法和實際場景?
- 線程池是為了解決大量的請求造成的服務(wù)器大量創(chuàng)建和銷毀線程所帶來的系統(tǒng)資源消耗颈墅,并且能夠有效控制系統(tǒng)的訪問量的一種解決方案;
- 線程池參數(shù):
- corePoolSize:核心線程數(shù)溯职;核心線程會一直存活精盅,及時沒有任務(wù)需要執(zhí)行;當(dāng)線程數(shù)小于核心線程數(shù)時谜酒,即使有線程空閑叹俏,線程池也會優(yōu)先創(chuàng)建新線程;設(shè)置allowCoreThreadTimeout=true(默認(rèn)false)時僻族,核心線程會超時關(guān)閉粘驰;創(chuàng)建完線程池之后線程池中的線程數(shù)量是0,當(dāng)任務(wù)需要執(zhí)行任務(wù)的時候就創(chuàng)建線程述么,如果任務(wù)數(shù)量超過了核心線程數(shù)蝌数,那么新的任務(wù)就會被放入等待隊列中,當(dāng)有線程執(zhí)行完任務(wù)之后度秘,就會把該線程放入線程池顶伞,然后從隊列中取出任務(wù)繼續(xù)執(zhí)行;
- maximumPoolSize:線程池最大線程數(shù)剑梳;當(dāng)線程數(shù)>=corePoolSize唆貌,且任務(wù)隊列已滿時。線程池會創(chuàng)建新線程來處理任務(wù)垢乙;當(dāng)線程數(shù)=maxPoolSize锨咙,且任務(wù)隊列已滿時,線程池會拒絕處理任務(wù)而拋出異常追逮;
- keepAliveTime:線程空閑時間酪刀;當(dāng)線程空閑時間達到keepAliveTime時,線程會退出钮孵,直到線程數(shù)量=corePoolSize骂倘;如果allowCoreThreadTimeout=true,則會直到線程數(shù)量=0油猫;
- TimeUnit:時間單位稠茂;
- BlockingQueue:阻塞隊列,實現(xiàn)類可以是ArrayBlokingQueue,LinkedBlockingQueue睬关,SynchronousQueue诱担;
- allowCoreThreadTimeout:允許核心線程超時;
- rejectedExecutionHandler:任務(wù)拒絕處理器电爹;
- 常用的線程池:
-
CachedThreadPool:
? 當(dāng)有新任務(wù)到來蔫仙,則插入到SynchronousQueue中,由于SynchronousQueue是同步隊列丐箩,因此會在池中尋找可用線程來執(zhí)行摇邦,若有可以線程則執(zhí)行,若沒有可用線程則創(chuàng)建一個線程來執(zhí)行該任務(wù)屎勘;若池中線程空閑時間超過指定時長施籍,則該線程會被銷毀。
? 返回ThreadPoolExecutor實例概漱,corePoolSize為0丑慎;maximumPoolSize為Integer.MAX_VALUE;keepAliveTime為60L瓤摧;unit為TimeUnit.SECONDS竿裂;workQueue為SynchronousQueue(同步隊列)
執(zhí)行很多短期異步的程序或者負(fù)載較輕的服務(wù)器
? 執(zhí)行很多短周期的程序或者負(fù)載較輕的服務(wù)器 -
FixedThreadPool:
? 創(chuàng)建可容納固定數(shù)量線程的池子,每隔線程的存活時間是無限的照弥,當(dāng)池子滿了就不在創(chuàng)建線程了腻异;如果池中的所有線程均在繁忙狀態(tài),對于新任務(wù)會進入無界的阻塞隊列LinkedBlockingQueue这揣;
? 返回ThreadPoolExecutor實例悔常,接收參數(shù)為所設(shè)定線程數(shù)量nThread,corePoolSize為nThread给赞,maximumPoolSize為nThread这嚣;keepAliveTime為0L(不限時);unit為:TimeUnit.MILLISECONDS塞俱;WorkQueue為:LinkedBlockingQueue<Runnable> 無解阻塞隊列;
? 執(zhí)行長期的任務(wù)吏垮,性能好很多障涯; -
SingleThreadExecutor
? 創(chuàng)建只有一個線程的線程池,且線程的存活時間是無限的膳汪;當(dāng)該線程正繁忙時唯蝶,對于新任務(wù)會進入阻塞隊列中(無界的阻塞隊列)
? FinalizableDelegatedExecutorService包裝的ThreadPoolExecutor實例,corePoolSize為1遗嗽;maximumPoolSize為1粘我;keepAliveTime為0L;unit為:TimeUnit.MILLISECONDS;workQueue為: LinkedBlockingQueue<Runnable> 無界阻塞隊列征字;
? 一個任務(wù)一個任務(wù)執(zhí)行的場景都弹; -
ScheduledThreadPool
? 創(chuàng)建一個固定大小的線程池,線程池內(nèi)線程存活時間無限制匙姜,線程池可以支持定時及周期性任務(wù)調(diào)度畅厢,如果所有線程均處于繁忙狀態(tài),對于新任務(wù)會進入DelayedWorkQueue隊列中(DelayedWorkQueue這是一種按照超時時間排序的隊列結(jié)構(gòu))氮昧;
? 創(chuàng)建ScheduledThreadPoolExecutor實例框杜,corePoolSize為傳遞來的參數(shù),maximumPoolSize為Integer.MAX_VALUE袖肥;keepAliveTime為0咪辱;unit為:TimeUnit.NANOSECONDS;workQueue為:DelayedWorkQueue椎组;
? 周期性執(zhí)行任務(wù)的場景油狂;
-
CachedThreadPool:
- 線程池任務(wù)執(zhí)行流程:
- 當(dāng)線程池小于corePoolSize時,新提交任務(wù)將創(chuàng)建一個新線程執(zhí)行任務(wù)庐杨,即使此時線程池中存在空閑線程选调。
- 當(dāng)線程池達到corePoolSize時,新提交任務(wù)將被放入workQueue中灵份,等待線程池中任務(wù)調(diào)度執(zhí)行
- 當(dāng)workQueue已滿仁堪,且maximumPoolSize>corePoolSize時,新提交任務(wù)會創(chuàng)建新線程執(zhí)行任務(wù)
- 當(dāng)提交任務(wù)數(shù)超過maximumPoolSize時填渠,新提交任務(wù)由RejectedExecutionHandler處理
- 當(dāng)線程池中超過corePoolSize線程弦聂,空閑時間達到keepAliveTime時,關(guān)閉空閑線程
- 當(dāng)設(shè)置allowCoreThreadTimeOut(true)時氛什,線程池中corePoolSize線程空閑時間達到keepAliveTime也將關(guān)閉莺葫;
- 介紹一下你認(rèn)識的集合框架,并解釋Hastable和ConcurrentHashMap相互的關(guān)聯(lián)和區(qū)別枪眉。
- 所謂集合框架指的就是Collection及其子孫捺檬,即List,Set贸铜,Queue堡纬,Map是一個比較特殊容器,還有兩個集合工具Collections和Arrays蒿秦;如下圖:
Java集合框架圖 -
List:即有序列表烤镐,特點是允許元素重復(fù),記錄數(shù)據(jù)存儲的順序棍鳖;其常見的實現(xiàn)類:
- 基于數(shù)組結(jié)構(gòu)實現(xiàn):ArrayList炮叶,Vector(與ArrayList的區(qū)別在于所有的數(shù)據(jù)操作方法都使用Synchronized修飾);
- 基于鏈表結(jié)構(gòu)實現(xiàn):LinkedList;
- Set:即無序列表镜悉,特點是元素不允許重復(fù)(實現(xiàn)hashCode和equals方法)祟辟,不記錄元素的存儲順序;其常見的實現(xiàn)類:HashSet积瞒,TreeSet川尖;
- Map:即存儲鍵值對(Entry)的容器,特點是不允許key重復(fù)茫孔,不記錄數(shù)據(jù)添加順序叮喳;常見的實現(xiàn)類有:HashMap,TreeMap缰贝,LinkedHashMap馍悟;
-
Queue:特點是只能從隊頭(top)取數(shù)據(jù),隊尾添加數(shù)據(jù)剩晴,先進先出(FIFO)锣咒,常見的實現(xiàn)類:
- 非阻塞隊列:
? PriorityQueue:維護了一個有序列表。加入到 Queue 中的元素根據(jù)它們的天然排序(Comparable/Comparator)
? ConcurrentLinkedQueue:基于鏈表結(jié)構(gòu)的赞弥、線程安全的隊列毅整。并發(fā)訪問不需要同步。因為它在隊列的尾部添加元素并從頭部刪除它們绽左,所以無需知道隊列的大械考怠;ConcurrentLinkedQueue 對公共集合的共享訪問就可以工作得很好拼窥。收集關(guān)于隊列大小的信息會很慢戏蔑,需要遍歷隊列;
? ArrayDeque:基于數(shù)組的雙端隊列鲁纠; - 阻塞隊列:
? ArrayBlockingQueue:基于數(shù)組的阻塞隊列實現(xiàn)总棵,在ArrayBlockingQueue內(nèi)部航瞭,維護了一個定長數(shù)組冰更,以便緩存隊列中的數(shù)據(jù)對象趋翻,這是一個常用的阻塞隊列硕淑,除了 一個定長數(shù)組外,ArrayBlockingQueue內(nèi)部還保存著兩個整形變量滥酥,分別標(biāo)識著隊列的頭部和尾部在數(shù)組中的位置结啼。ArrayBlockingQueue在生產(chǎn)者放入數(shù)據(jù)和消費者獲取數(shù)據(jù)坎缭,都是共用同一個鎖對象白群,由此也意味著兩者無法真正并行運行,這點尤其不同于 LinkedBlockingQueue硬霍;按照實現(xiàn)原理來分析帜慢,ArrayBlockingQueue完全可以采用分離鎖,從而實現(xiàn)生產(chǎn)者和消費者操作的 完全并行運行。Doug Lea之所以沒這樣去做粱玲,也許是因為ArrayBlockingQueue的數(shù)據(jù)寫入和獲取操作已經(jīng)足夠輕巧躬柬,以至于引入獨立的鎖機制,除了給代碼帶來額外的復(fù)雜性外抽减,其在性能上完全占不到任何便宜允青。 ArrayBlockingQueue和LinkedBlockingQueue間還有一個明顯的不同之處在于,前者在插入或刪除元素時不會產(chǎn)生或銷毀任 何額外的對象實例卵沉,而后者則會生成一個額外的Node對象颠锉。這在長時間內(nèi)需要高效并發(fā)地處理大批量數(shù)據(jù)的系統(tǒng)中,其對于GC的影響還是存在一定的區(qū)別史汗。而 在創(chuàng)建ArrayBlockingQueue時琼掠,我們還可以控制對象的內(nèi)部鎖是否采用公平鎖,默認(rèn)采用非公平鎖停撞。
? LinkedBlockingQueue:基于鏈表的阻塞隊列瓷蛙,同ArrayListBlockingQueue類似,其內(nèi)部也維持著一個數(shù)據(jù)緩沖隊列(該隊列由一個鏈表構(gòu)成)戈毒,當(dāng)生產(chǎn)者往隊列 中放入一個數(shù)據(jù)時艰猬,隊列會從生產(chǎn)者手中獲取數(shù)據(jù),并緩存在隊列內(nèi)部埋市,而生產(chǎn)者立即返回冠桃;只有當(dāng)隊列緩沖區(qū)達到最大值緩存容量時 (LinkedBlockingQueue 可以通過構(gòu)造函數(shù)指定該值),才會阻塞生產(chǎn)者隊列恐疲,直到消費者從隊列中消費掉一份數(shù)據(jù)腊满,生產(chǎn)者線程會被喚醒,反之對于消費者這端的處理也基于同樣的原理培己。而LinkedBlockingQueue之所以能夠高效的處理并發(fā)數(shù)據(jù)碳蛋,還因為其對于生產(chǎn)者端和消費者端分別采用了獨立的鎖來控制數(shù)據(jù)同步,這也意味著在高并發(fā)的情況下生產(chǎn)者和消費者可以并行地操作隊列中的數(shù)據(jù)省咨,以此來提高整個隊列的并發(fā)性能肃弟。
作為開發(fā)者,我們需要注意的是零蓉,如果構(gòu)造一個LinkedBlockingQueue對象笤受,而沒有指定其容量大小,LinkedBlockingQueue會默認(rèn) 一個類似無限大小的容量(Integer.MAX_VALUE)敌蜂,這樣的話箩兽,如果生產(chǎn)者的速度一旦大于消費者的速度,也許還沒有等到隊列滿阻塞產(chǎn)生章喉,系統(tǒng)內(nèi)存就有可能已被消耗殆盡了汗贫。
? LinkedBlockingDeque:基于鏈表的FIFO雙端阻塞隊列身坐。
? PriorityBlockingQueue:帶優(yōu)先級的無界阻塞隊列,基于數(shù)組落包,數(shù)據(jù)結(jié)構(gòu)為二叉堆部蛇,數(shù)組第一個也是樹的根節(jié)點總是最小值;優(yōu)先級的判斷通過構(gòu)造函數(shù)傳入的Compator對象來決定咐蝇,但需要注意的是PriorityBlockingQueue并不會阻塞數(shù)據(jù)生產(chǎn)者涯鲁,而只會在沒有可消費的數(shù)據(jù)時,阻塞數(shù)據(jù)的消費者有序。因此使用的時候要特別注意抹腿,生產(chǎn)者生產(chǎn)數(shù)據(jù)的速度絕對不能快于消費者消費數(shù)據(jù)的速度, 否則時間一長笔呀,會最終耗盡所有的可用堆內(nèi)存空間幢踏。在實現(xiàn)PriorityBlockingQueue時,內(nèi)部控制線程同步的鎖采用的是公平鎖许师。
? SynchronousQueue :并發(fā)同步阻塞隊列房蝉,本身不帶有空間來存儲任何元素,使用上可以選擇公平模式和非公平模式微渠;一種無緩沖的等待隊列搭幻,類似于無中介的直接交易,有點像原始社會中的生產(chǎn)者和消費者逞盆,生產(chǎn)者拿著產(chǎn)品去集市銷售給產(chǎn)品的最終消費者檀蹋,而消費者必須親自去 集市找到所要商品的直接生產(chǎn)者,如果一方?jīng)]有找到合適的目標(biāo)云芦,那么對不起俯逾,大家都在集市等待。相對于有緩沖的BlockingQueue來說舅逸,少了一個中 間經(jīng)銷商的環(huán)節(jié)(緩沖區(qū))桌肴,如果有經(jīng)銷商,生產(chǎn)者直接把產(chǎn)品批發(fā)給經(jīng)銷商琉历,而無需在意經(jīng)銷商最終會將這些產(chǎn)品賣給那些消費者坠七,由于經(jīng)銷商可以庫存一部分商 品,因此相對于直接交易模式旗笔,總體來說采用中間經(jīng)銷商的模式會吞吐量高一些(可以批量買賣)彪置;但另一方面,又因為經(jīng)銷商的引入蝇恶,使得產(chǎn)品從生產(chǎn)者到消費者 中間增加了額外的交易環(huán)節(jié)拳魁,單個產(chǎn)品的及時響應(yīng)性能可能會降低。聲明一個SynchronousQueue有兩種不同的方式撮弧,它們之間有著不太一樣的行為潘懊。公平模式和非公平模式的區(qū)別: 如果采用公平模式:SynchronousQueue會采用公平鎖耀盗,并配合一個FIFO隊列來阻塞多余的生產(chǎn)者和消費者,從而體系整體的公平策略卦尊;非公平模式(SynchronousQueue默認(rèn)):SynchronousQueue采用非公平鎖,同時配合一個LIFO(后進先出法 Last In First Out )隊列來管理多余的生產(chǎn)者和消費者舌厨,而后一種模式岂却,如果生產(chǎn)者和消費者的處理速度有差距,則很容易出現(xiàn)饑渴的情況裙椭,即可能有某些生產(chǎn)者或者是消費者的數(shù)據(jù)永遠(yuǎn)都得不到處理躏哩。
? DelayQueue:DelayQueue中的元素只有當(dāng)其指定的延遲時間到了,才能夠從隊列中獲取到該元素揉燃。DelayQueue是一個沒有大小限制的隊列扫尺,因此往隊列中插入數(shù)據(jù)的操作(生產(chǎn)者)永遠(yuǎn)不會被阻塞,而只有獲取數(shù)據(jù)的操作(消費者)才會被阻塞炊汤。DelayQueue使用場景較少正驻,但都相當(dāng)巧妙,常見的例子比如使用一個DelayQueue來管理一個超時未響應(yīng)的連接隊列抢腐。
- 非阻塞隊列:
- LinkedBlockingQueue和ArrayBlockingQueue的說明:
- 一般如果線程池任務(wù)隊列采用LinkedBlockingQueue隊列的話姑曙,那么不會拒絕任何任務(wù)(因為隊列大小沒有限制),這種情況下迈倍,ThreadPoolExecutor最多僅會按照最小線程數(shù)來創(chuàng)建線程伤靠,也就是說線程池大小被忽略了。
- 如果線程池任務(wù)隊列采用ArrayBlockingQueue隊列的話啼染,那么ThreadPoolExecutor將會采取一個非常負(fù)責(zé)的算法宴合,比如假定線程池的最小線程數(shù)(核心線程數(shù))為4,最大為8迹鹅,所用的ArrayBlockingQueue最大為10卦洽。隨著任務(wù)到達并被放到隊列中,線程池中最多運行4個線程(即最小線程數(shù))徒欣。即使隊列完全填滿逐样,也就是說有10個處于等待狀態(tài)的任務(wù),ThreadPoolExecutor也只會利用4個線程打肝。如果隊列已滿脂新,而又有新任務(wù)進來,此時才會啟動一個新線程粗梭,這里不會因為隊列已滿而拒接該任務(wù)争便,相反會啟動一個新線程。新線程會運行隊列中的第一個任務(wù)断医,為新來的任務(wù)騰出空間滞乙。該池大部分時間僅使用核心線程(4個)奏纪,即使有適量的任務(wù)在隊列中等待運行。這時線程池就可以用作節(jié)流閥斩启。如果擠壓的請求變得非常多序调,這時該池就會嘗試運行更多的線程來從隊列中取出任務(wù)并執(zhí)行;這時第二個節(jié)流閥—最大線程數(shù)(8個)就起作用了兔簇。
- Hastable和ConcurrentHashMap
- 二者都可在多線程環(huán)境下使用发绢,并能保證線程的安全運行
- Hashtable中所有對數(shù)據(jù)的操作的方法都是用synchronized關(guān)鍵字進行修飾,也就是說垄琐,給整體數(shù)據(jù)加上了一塊大大的鎖边酒,當(dāng)數(shù)據(jù)量變大的時候,一旦內(nèi)部出現(xiàn)迭代之類的耗時操作狸窘,外部將不能訪問數(shù)據(jù)墩朦,只能被阻塞,進而等待鎖釋放翻擒,即性能不穩(wěn)定氓涣;
- ConcurrentHashMap的數(shù)據(jù)結(jié)構(gòu)在JDK8中有了比較大的變化,而且對于性能來說是比較大的提升韭寸;在JDK8之前春哨,ConcurrentHashMap使用的是數(shù)組、鏈表恩伺、Segment分段鎖(ReentrantLock)實現(xiàn)赴背,而在JDK8的時候的改善是:干掉了Segment分段鎖,添加了紅黑樹的數(shù)據(jù)結(jié)構(gòu)晶渠,默認(rèn)情況下凰荚,當(dāng)某個鏈表的長度大于8的時候,這個鏈表自動轉(zhuǎn)化為一個紅黑樹褒脯,我們都知道便瑟,紅黑樹是一個平衡樹,大大的提高了數(shù)據(jù)的查詢插入的效率番川,但是其算法比較復(fù)雜到涂,而且使用CAS+Synchronized的方式保證其數(shù)據(jù)的安全性。
- 所謂集合框架指的就是Collection及其子孫捺檬,即List,Set贸铜,Queue堡纬,Map是一個比較特殊容器,還有兩個集合工具Collections和Arrays蒿秦;如下圖:
- 說說常見的垃圾回收器有哪些颁督?cms回收器有哪幾個過程践啄,停頓幾次,會不會產(chǎn)生內(nèi)存碎片沉御?老年代產(chǎn)生內(nèi)存碎片會有什么問題屿讽?詳細(xì)參考這里
- 垃圾回收器種類
- 新生代的收集器包括:
? Serial
? PraNew
? Parallel Scavenge - 老年代的收集器包括:
? SerialOld
? ParallelOld
? CMS - 回收整個Java堆(新生代和老年代)
? G1收集器
- 新生代的收集器包括:
- 垃圾回收器詳解
- Serial:串行收集器-復(fù)制算法。該收集器是新生代單線程收集器吠裆,優(yōu)點是簡單高效伐谈,算是最基本烂完、發(fā)展歷史最悠久的收集器。它在進行垃圾收集時诵棵,必須暫停其他所有的工作線程抠蚣,直到它收集完成。而且Serial收集器依然是虛擬機運行在Client模式下默認(rèn)新生代收集器履澳,對于運行在Client模式下的虛擬機來說是一個很好的選擇柱徙。
- PraNew收集器-復(fù)制算法。該收集器是新生代并行收集器奇昙,本質(zhì)上是Serial收集器的多線程版本,包括Serial收集器可用的所有控制參數(shù)敌完、收集算法储耐、Stop The World、對象分配規(guī)則滨溉、回收策略等都與Serial 收集器完全一樣什湘。
- 垃圾回收器種類