合理使用線程池的好處:
- 降低資源消耗伙单。通過重復(fù)利用已創(chuàng)建的線程降低線程創(chuàng)建和銷毀造成的消耗获高。
- 提高響應(yīng)速度。當(dāng)任務(wù)到達(dá)時车份,任務(wù)可以不需要的等到線程創(chuàng)建就能立即執(zhí)行谋减。
- 提高線程的可管理性牡彻。線程是稀缺資源扫沼,如果無限制的創(chuàng)建,不僅會消耗系統(tǒng)資源庄吼,還會降低系統(tǒng)的穩(wěn)定性缎除,使用線程池可以進(jìn)行統(tǒng)一的分配,調(diào)優(yōu)和監(jiān)控总寻。但是要做到合理的利用線程池器罐,必須對其原理了如指掌
Executor架構(gòu)
在HotSpot虛擬機中,Java中的線程將會被一一映射為操作系統(tǒng)的線程 在Java虛擬機層面渐行,用戶將多個任務(wù)提交給Executor框架,Executor負(fù)責(zé)分配線程執(zhí)行它們轰坊; 在操作系統(tǒng)層面,操作系統(tǒng)再將這些線程分配給處理器執(zhí)行
Executor框架中的所有類可以分成三類:
1.任務(wù) 任務(wù)有兩種類型:Runnable和Callable祟印。
2.任務(wù)執(zhí)行器 Executor框架最核心的接口是Executor肴沫,它表示任務(wù)的執(zhí)行器。
Executor的子接口為ExecutorService蕴忆。
ExecutorService有兩大實現(xiàn)類:ThreadPoolExecutor和ScheduledThreadPoolExecutor颤芬。
3.執(zhí)行結(jié)果
Future接口表示異步的執(zhí)行結(jié)果,它的實現(xiàn)類為FutureTask套鹅。
ThreadPoolExecutor類
Executor接口
Executor接口只有一個execute方法站蝠,用來替代通常創(chuàng)建或啟動線程的方法。
ExecutorService接口
ExecutorService接口繼承自Executor接口卓鹿,提供了管理終止的方法菱魔,以及可為跟蹤一個或多個異步任務(wù)執(zhí)行狀況而生成 Future 的方法。增加了shutDown()吟孙,shutDownNow()豌习,invokeAll()存谎,invokeAny()和submit()等方法。如果需要支持即時關(guān)閉肥隆,也就是shutDownNow()方法既荚,則任務(wù)需要正確處理中斷。
AbstractExecutorService抽象類
提供ExecutorService接口的默認(rèn)實現(xiàn)方法栋艳。
創(chuàng)建線程池的方法
ExecutorService threadPool = new ThreadPoolExecutor(1, 5, 30, TimeUnit.MILLISECONDS,new LinkedBlockingDeque<Runnable>(1024), Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
其中線程工廠可以使用guava包中的方法創(chuàng)建:
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("demo-pool-%d").build();
參數(shù)說明:
- corePoolSize
核心線程數(shù)恰聘,默認(rèn)情況下核心線程會一直存活,即使處于閑置狀態(tài)也不會受存keepAliveTime限制吸占。除非將allowCoreThreadTimeOut設(shè)置為true晴叨。 - maximumPoolSize
線程池所能容納的最大線程數(shù)。超過這個數(shù)的線程將被阻塞矾屯。當(dāng)任務(wù)隊列為沒有設(shè)置大小的LinkedBlockingDeque時兼蕊,這個值無效。 - keepAliveTime
非核心線程的閑置超時時間件蚕,超過這個時間就會被回收孙技。 - workQueue
線程池中的任務(wù)隊列。常用的有三種隊列排作,SynchronousQueue,LinkedBlockingDeque,ArrayBlockingQueue牵啦。 - threadFactory
線程工廠,提供創(chuàng)建新線程的功能妄痪。 - RejectedExecutionHandler
當(dāng)線程池中的資源已經(jīng)全部使用哈雏,添加新線程被拒絕時,會調(diào)用RejectedExecutionHandler的rejectedExecution方法衫生。
線程池規(guī)則:
1.如果線程數(shù)量<=核心線程數(shù)量裳瘪,那么直接啟動一個核心線程來執(zhí)行任務(wù),不會放入隊列中罪针。
2.如果線程數(shù)量>核心線程數(shù)彭羹,但<=最大線程數(shù),并且任務(wù)隊列是LinkedBlockingDeque的時候站故,超過核心線程數(shù)量的任務(wù)會放在任務(wù)隊列中排隊皆怕。
3.如果線程數(shù)量>核心線程數(shù),但<=最大線程數(shù)西篓,并且任務(wù)隊列是SynchronousQueue的時候愈腾,線程池會創(chuàng)建新線程執(zhí)行任務(wù),這些任務(wù)也不會被放在任務(wù)隊列中岂津。這些線程屬于非核心線程虱黄,在任務(wù)完成后,閑置時間達(dá)到了超時時間就會被清除吮成。
4.如果線程數(shù)量>核心線程數(shù)橱乱,并且>最大線程數(shù)辜梳,當(dāng)任務(wù)隊列是LinkedBlockingDeque,會將超過核心線程的任務(wù)放在任務(wù)隊列中排隊泳叠。也就是當(dāng)任務(wù)隊列是LinkedBlockingDeque并且沒有大小限制時作瞄,線程池的最大線程數(shù)設(shè)置是無效的,他的線程數(shù)最多不會超過核心線程數(shù)危纫。
5.如果線程數(shù)量>核心線程數(shù)宗挥,并且>最大線程數(shù),當(dāng)任務(wù)隊列是SynchronousQueue的時候种蝶,會因為線程池拒絕添加任務(wù)而拋出異常契耿。
使coreThread失效
之前設(shè)置的keepAliveTime參數(shù)只能使超過此閾值的非核心線程失效,使用allowCoreThreadTimeOut(boolean value)方法將allowCoreThreadTimeOut設(shè)置為true則可以將該策略應(yīng)用于核心線程螃征。
http://www.ideabuffer.cn/2017/04/04/%E6%B7%B1%E5%85%A5%E7%90%86%E8%A7%A3Java%E7%BA%BF%E7%A8%8B%E6%B1%A0%EF%BC%9AThreadPoolExecutor/
https://blog.csdn.net/z_s_z2016/article/details/81674893