Java線程池Executor怎么使用

第Java線程池Executor怎么使用使用Executors創(chuàng)建線程池

使用Executors可以創(chuàng)建四種線程池：分別對應(yīng)上邊提到的四種線程池初始化方法

Executors.newCachedThreadPool

newCachedThreadPool是一個(gè)根據(jù)需要創(chuàng)建新線程的線程池，當(dāng)一個(gè)任務(wù)提交時(shí)，corePoolSize為0不創(chuàng)建核心線程，SynchronousQueue是一個(gè)不存儲元素的隊(duì)列，可以理解為隊(duì)里永遠(yuǎn)是滿的，因此最終會創(chuàng)建非核心線程來執(zhí)行任務(wù)。對于非核心線程空閑60s時(shí)將被回收。因?yàn)镮nteger.MAX_VALUE非常大，可以認(rèn)為是可以無限創(chuàng)建線程的，在資源有限的情況下容易引起OOM異常。

//創(chuàng)建newCachedThreadPool線程池源碼

publicstaticExecutorServicenewCachedThreadPool(){

*corePoolSize：0，核心線程池的數(shù)量為0

*maximumPoolSize：Integer.MAX_VALUE，可以認(rèn)為最大線程數(shù)是無限的

*keepAliveTime：60L

*unit:秒

*workQueue:SynchronousQueue

returnnewThreadPoolExecutor(0,Integer.MAX_VALUE,

60L,TimeUnit.SECONDS,

newSynchronousQueueRunnable

}

使用案例：

publicstaticvoidmAIn(String[]args){

ExecutorServiceexecutor=Executors.newCachedThreadPool();

for(inti=0;ii++){

finalintindex=i;

executor.execute(newRunnable(){

@Override

publicvoidrun(){

(task:{},index);

}

值得注意的一點(diǎn)是，newCachedThreadPool的返回值是ExecutorService類型，該類型只包含基礎(chǔ)的線程池方法，但卻不包含線程監(jiān)控相關(guān)方法，因此在使用返回值為ExecutorService的線程池類型創(chuàng)建新線程時(shí)要考慮到具體情況。

Executors.newSingleThreadExecutor

newSingleThreadExecutor是單線程線程池，只有一個(gè)核心線程，用唯一的一個(gè)共用線程執(zhí)行任務(wù)，保證所有任務(wù)按指定順序執(zhí)行（FIFO、優(yōu)先級hellip;）

//newSingleThreadExecutor創(chuàng)建線程池源碼

publicstaticExecutorServicenewSingleThreadExecutor(){

*corePoolSize:1，核心線程池的數(shù)量為1

*maximumPoolSize:1，只可以創(chuàng)建一個(gè)非核心線程

*keepAliveTime:0L

*unit=秒

*workQueue=LinkedBlockingQueue

returnnewFinalizableDelegatedExecutorService

(newThreadPoolExecutor(1,1,

0L,TimeUnit.MILLISECONDS,

newLinkedBlockingQueueRunnable()));

}

當(dāng)一個(gè)任務(wù)提交時(shí)，首先會創(chuàng)建一個(gè)核心線程來執(zhí)行任務(wù)，如果超過核心線程的數(shù)量，將會放入隊(duì)列中，因?yàn)長inkedBlockingQueue是長度為Integer.MAX_VALUE的隊(duì)列，可以認(rèn)為是無界隊(duì)列，因此往隊(duì)列中可以插入無限多的任務(wù)，在資源有限的時(shí)候容易引起OOM異常，同時(shí)因?yàn)闊o界隊(duì)列，maximumPoolSize和keepAliveTime參數(shù)將無效，壓根就不會創(chuàng)建非核心線程。

Executors.newFixedThreadPool

定長線程池，核心線程數(shù)和最大線程數(shù)由用戶傳入，可以設(shè)置線程的最大并發(fā)數(shù)，超出在隊(duì)列等待

//newFixedThreadPool創(chuàng)建線程池源碼

publicstaticExecutorServicenewFixedThreadPool(intnThreads){

*corePoolSize:核心線程的數(shù)量為自定義輸入nThreads

*maximumPoolSize：最大線程的數(shù)量為自定義輸入nThreads

*keepAliveTime：0L

*unit：秒

*workQueue：LinkedBlockingQueue

returnnewThreadPoolExecutor(nThreads,nThreads,

0L,TimeUnit.MILLISECONDS,

newLinkedBlockingQueueRunnable

}

newFixedThreadPool和SingleThreadExecutor類似，唯一的區(qū)別就是核心線程數(shù)不同，并且由于使用的是LinkedBlockingQueue，在資源有限的時(shí)候容易引起OOM異常。

Executors.newScheduledThreadPool

定長線程池，核心線程數(shù)由用戶傳入，支持定時(shí)和周期任務(wù)執(zhí)行

//newScheduledThreadPool創(chuàng)建線程池源碼

publicstaticScheduledExecutorServicenewScheduledThreadPool(intcorePoolSize){

returnnewScheduledThreadPoolExecutor(corePoolSize);

publicScheduledThreadPoolExecutor(intcorePoolSize){

*corePoolSize:核心線程的數(shù)量為自定義輸入corePoolSize

*maximumPoolSize：最大線程的數(shù)量為Integer.MAX_VALUE

*keepAliveTime：0L

*unit：納秒

*workQueue：DelayedWorkQueue

super(corePoolSize,Integer.MAX_VALUE,0,NANOSECONDS,

newDelayedWorkQueue());

}

當(dāng)一個(gè)任務(wù)提交時(shí)，corePoolSize為自定義輸入，首先創(chuàng)建核心線程，核心線程滿了之后，因此最終會創(chuàng)建非核心線程來執(zhí)行任務(wù)。非核心線程使用后將被回收。因?yàn)镮nteger.MAX_VALUE非常大，可以認(rèn)為是可以無限創(chuàng)建線程的，在資源有限的情況下容易引起OOM異常。因?yàn)槭褂玫腄elayedWorkQueue可以實(shí)現(xiàn)定時(shí)和周期任務(wù)。ScheduledExecutorService提供了三種方法可以使用：

schedule：延遲后執(zhí)行任務(wù)scheduleAtFixedRate：以指定的速率執(zhí)行任務(wù)scheduleWithFixedDelay：以指定的延遲執(zhí)行任務(wù)使用案例：

publicstaticvoidmain(String[]args){

ScheduledExecutorServiceexecutorService=Executors.newScheduledThreadPool(1);

//executorService.schedule(newRunnable(){

//@Override

//publicvoidrun(){

//log.warn(schedulerun

////延遲3秒后執(zhí)行

//},3,TimeUnit.SECONDS);

//executorService.shutdown();

//executorService.scheduleWithFixedDelay(newRunnable(){

//@Override

//publicvoidrun(){

//log.warn(scheduleWithFixedDelayrun

////延遲一秒后每隔3秒執(zhí)行

//},1,3,TimeUnit.SECONDS);

executorService.scheduleAtFixedRate(newRunnable(){

@Override

publicvoidrun(){

log.warn(schedulerun

//延遲一秒后每隔3秒執(zhí)行

},1,3,TimeUnit.SECONDS);

*定時(shí)器調(diào)度，不推薦使用，