在多線程編程中創(chuàng)建線程池的時(shí)候,一般禁止使用Executors.newFixedThreadPool(8)方式創(chuàng)建線程池,這是一種偷懶的行為。一般使用
new ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
這種方式創(chuàng)建。
構(gòu)造函數(shù)里傳入的參數(shù)將會(huì)直接影響線程池的效率,因此必須要知道這些參數(shù)的意義。
- corePoolSize: 線程池維持的線程數(shù)量,即使這些線程是空閑的,除非設(shè)置
allowCoreThreadTimeOut為true - maximumPoolSize: 線程池允許的最大線程數(shù)量
- keepAliveTime: 當(dāng)前線程數(shù)大于
corePoolSize,多余的空閑線程存活時(shí)間 - unit:
keepAliveTime參數(shù)的時(shí)間單位 - workQueue: 任務(wù)隊(duì)列
- threadFactory: 線程創(chuàng)建工廠
- handler: 任務(wù)隊(duì)列滿了導(dǎo)致阻塞時(shí)新任務(wù)的拒絕策略
上面的解釋是JDK的注釋,寫的也是云里霧里,下面進(jìn)行一一解釋。
corePoolSize
線程池默認(rèn)初始化時(shí),allowCoreThreadTimeOut為false, 也就是說默認(rèn)情況下,線程池的線程數(shù)最小是corePoolSize, 即使這些線程是空閑的,數(shù)量也會(huì)維持在corePoolSize。線程池對(duì)象有個(gè)方法allowCoreThreadTimeOut(boolean value), 當(dāng)傳入true的時(shí)候,表示核心線程池的線程在沒有任務(wù)到達(dá)的時(shí)候,keepAliveTime時(shí)間后關(guān)閉。
maximumPoolSize
maximumPoolSize 表示線程池的最大線程數(shù)量。當(dāng)線程池的數(shù)量達(dá)到corePoolSize,并且任務(wù)隊(duì)列已經(jīng)滿了,則會(huì)繼續(xù)創(chuàng)建新線程直到數(shù)量達(dá)到maximumPoolSize。但是請(qǐng)注意,當(dāng)workQueue傳入的是無界隊(duì)列的時(shí)候,maximumPoolSize參數(shù)是不起作用的,線程池的最大數(shù)量會(huì)一直是corePoolSize。
workQueue
workQueue參數(shù)需要傳入一個(gè)阻塞隊(duì)列,隊(duì)列分為有界隊(duì)列(比如ArrayBlockingQueue)和無界隊(duì)列(比如LinkedBlockingQueue),傳入無界隊(duì)列時(shí),maximumPoolSize參數(shù)是不起作用的。
handler
配置拒絕策略,拒絕策略有:
- AbortPolicy 直接拒絕新任務(wù),并拋出
RejectedExecutionException異常 - CallerRunsPolicy 用當(dāng)前線程的
execute方法執(zhí)行被拒絕的任務(wù),如果執(zhí)行器已經(jīng)關(guān)閉則丟棄任務(wù) - DiscardPolicy 默默地丟棄新到的任務(wù)
- DiscardOldestPolicy 丟棄最老的一個(gè)未執(zhí)行的任務(wù)并執(zhí)行當(dāng)前任務(wù)
要知道,線程池初始化的時(shí)候,池子里是沒有線程的。
那corePoolSize配置成多大合適呢?一般來說,CPU密集型任務(wù)可以少配置線程數(shù),大概和機(jī)器的cpu核數(shù)相當(dāng)。IO密集型時(shí),大部分線程都阻塞,故需要多配置線程數(shù),2*cpu核數(shù)