為什么要引入線程池
- 降低資源消耗：通過重復(fù)利用已創(chuàng)建的線程降低創(chuàng)建和銷毀造成的消耗。
- 提高響應(yīng)速度：當(dāng)任務(wù)到達(dá)時(shí)，任務(wù)可以不需要等到線程創(chuàng)建就能立即執(zhí)行。
- 提高線程的可管理性：線程是稀缺資源，如果無限制的創(chuàng)建，不僅會(huì)消耗系統(tǒng)資源，還會(huì)降低系統(tǒng)的穩(wěn)定性，使用線程池可以進(jìn)行統(tǒng)一的分配，調(diào)優(yōu)和監(jiān)控。
默認(rèn)線程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 100, 10, TimeUnit.SECONDS, new PriorityBlockingQueue<Runnable>());
for(int index=0; index=100; index++){
executor.execute(new Runnable());
}
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
| 參數(shù) | 說明 |
|---|---|
| corePoolSize | 線程池中核心線程數(shù)量 |
| maximumPoolSize | 最大能創(chuàng)建的線程數(shù)量 |
| keepAliveTime | 非核心線程最大存活時(shí)間 |
| unit | keepAliveTime的時(shí)間單位 |
| workQueue | 等待隊(duì)列。當(dāng)任務(wù)提交時(shí)，如果線程池中的線程數(shù)量大于等于corePoolSize的時(shí)候，把該任務(wù)放入等待隊(duì)列 |
| threadFactory | 線程創(chuàng)建工廠。默認(rèn)使用Executors.defaultThreadFactory()來創(chuàng)建線程，線程具有相同的NORM_PRIORITY優(yōu)先級(jí)并且是非守護(hù)線程 |
| handler | 線程池的飽和拒絕策略。如果阻塞隊(duì)列滿了并且沒有空閑的線程，這時(shí)如果繼續(xù)提交任務(wù)，就需要采取一種策略處理該任務(wù)。 |
Executors提供的線程池
//單一線程數(shù),同時(shí)只有一個(gè)線程存活,但線程等待隊(duì)列無界
Executors.newSingleThreadExecutor();
//線程可復(fù)用線程池,核心線程數(shù)為0，最大可創(chuàng)建的線程數(shù)為Interger.max,線程復(fù)用存活時(shí)間是60s.
Executors.newCachedThreadPool();
//固定線程數(shù)量的線程池
Executors.newFixedThreadPool(int corePoolSize);
//可執(zhí)行定時(shí)任務(wù),延遲任務(wù)的線程池
Executors.newScheduledThreadPool(int corePoolSize);
關(guān)鍵函數(shù)
void execute(Runnable run)//提交任務(wù),交由線程池調(diào)度
void shutdown()//關(guān)閉線程池,等待任務(wù)執(zhí)行完成
void shutdownNow()//關(guān)閉線程池，不等待任務(wù)執(zhí)行完成
int getTaskCount()//返回線程池找中所有任務(wù)的數(shù)量
int getCompletedTaskCount()//返回線程池中已執(zhí)行完成的任務(wù)數(shù)量
int getPoolSize()//返回線程池中已創(chuàng)建線程數(shù)量
int getActiveCount()//返回當(dāng)前正在運(yùn)行的線程數(shù)量
狀態(tài)流轉(zhuǎn)
線程池狀態(tài)
execute提交任務(wù)
execute
