多線程 -- 線程池
1. 作用
- 重用線程, 減少線程創(chuàng)建銷毀帶來的開銷;
- 限制最先線程并發(fā)數(shù)目, 避免大量線程之間因相互搶占系統(tǒng)資源而導(dǎo)致的阻塞現(xiàn)象;
2. 創(chuàng)建與使用
通常我們通過Executors類提供的工廠方法創(chuàng)建線程池;
而線程池的實(shí)際實(shí)現(xiàn)是ThreadPoolExecutor, 它提供一系列的參數(shù)來配置線程池;
我們通過ExecutorService去管理線程池, 用它去提交任務(wù), 關(guān)閉線程池; 它是一個接口, ThreadPoolExecutor實(shí)現(xiàn)了該接口;
我們提交任務(wù)給線程池去執(zhí)行, 而任務(wù)由Executor(執(zhí)行器)去提交, Executor是一個接口, ExecutorService又繼承了該接口;
2.1 ThreadPoolExecutor
線程池的實(shí)際實(shí)現(xiàn), 它的構(gòu)造方法提供了一系列的參數(shù)用于我們配置線程池;
ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler);
corePoolSize & maximumPoolSize (核心和最大池大小)
當(dāng)新任務(wù)在方法 execute(java.lang.Runnable) 中提交時项秉，如果運(yùn)行的線程少于 corePoolSize，則創(chuàng)建新線程來處理請求单默，即使其他輔助線程是空閑的坞生。如果運(yùn)行的線程多于 corePoolSize 而少于 maximumPoolSize天通，則僅當(dāng)隊(duì)列滿時才創(chuàng)建新線程;
keepAliveTime & unit (保持活動時間)
如果池中當(dāng)前有多于 corePoolSize 的線程，則這些多出的線程在空閑時間超過 keepAliveTime 時將會終止;
默認(rèn)情況下, 核心線程會一直存活, allowCoreThreadTimeOut(boolean)設(shè)置為true時, 超時策略同樣會作用于核心線程;
workQueue (工作隊(duì)列)
線程池中的工作隊(duì)列; 通過execute提交的Runnable都會保存在這兒; 具體情況如下：
- 如果運(yùn)行的線程少于 corePoolSize，則 Executor 始終首選添加新的線程低淡，而不進(jìn)行排隊(duì)台谢。（如果當(dāng)前運(yùn)行的線程小于corePoolSize寻狂，則任務(wù)根本不會存放，添加到queue中朋沮，而是直接抄家伙（thread）開始運(yùn)行）
- 如果運(yùn)行的線程等于或多于 corePoolSize蛇券，則 Executor 始終首選將請求加入隊(duì)列，而不添加新的線程樊拓。
- 如果無法將請求加入隊(duì)列纠亚，則創(chuàng)建新的線程，除非創(chuàng)建此線程超出 maximumPoolSize筋夏，在這種情況下蒂胞，任務(wù)將被拒絕。
threadFactory
線程工廠; 為線程池提供Thread對象; 可以自定義ThreadFactory, 為線程池中的thread添加屬性;
RejectedExecutionHandler
當(dāng)線程池已經(jīng)關(guān)閉, 或者任務(wù)隊(duì)列已滿而無法執(zhí)行新任務(wù)時, execute會調(diào)用RejectedExecutionHandler去處理;
默認(rèn)情況下, 會直接拋出 RejectedExecutionExecption ;
hook方法
可重寫的 beforeExecute(Runnable) 和 afterExecute(Throwable) 方法条篷，這兩種方法分別在執(zhí)行每個任務(wù)之前和之后調(diào)用骗随。
它們可用于操縱執(zhí)行環(huán)境;例如重新初始化 ThreadLocal、搜集統(tǒng)計信息或添加日志條目赴叹。此外鸿染，還可以重寫方法 terminated() 來執(zhí)行 Executor 完全終止后需要完成的所有特殊處理;
3 Executors
Executors 系統(tǒng)系統(tǒng)的線程池的工廠方法; 可以產(chǎn)生如下幾種常用的線程池;
- newCachedThreadPool 無核心線程,輔助線程無上限, 超時60s的線程池
- newFixedThreadPool 固定線程數(shù)的線程池
- newSingleThreadExecutor 只有一個線程, 所有任務(wù)單個依次執(zhí)行
- newScheduledThreadPool 可以提交延遲任務(wù),或者定期任務(wù)的線程池
- newSingleThreadScheduledExecutor
4 使用方法
- 創(chuàng)建一個線程池, 使用Executors中的靜態(tài)方法創(chuàng)建一個線程池
- 調(diào)用
submit方法提交一個Runnable或者Callable對象 - 如果要取消一個任務(wù), 或如果提交的是Callable對象, 就需要保存好返回的Future對象
- 當(dāng)不再提交任何任務(wù)時, 調(diào)用
shutdown方法
