線程池的好處

第一：降低資源消耗。通過重復(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)控。但是要做到合理的利用線程池，必須對(duì)其原理了如指掌

線程池的主要工作流程

從上圖我們可以看出，當(dāng)提交一個(gè)新任務(wù)到線程池時(shí)，線程池的處理流程如下：

首先線程池判斷基本線程池是否已滿？沒滿，創(chuàng)建一個(gè)工作線程來執(zhí)行任務(wù)。滿了，則進(jìn)入下個(gè)流程。

其次線程池判斷工作隊(duì)列是否已滿？沒滿，則將新提交的任務(wù)存儲(chǔ)在工作隊(duì)列里。滿了，則進(jìn)入下個(gè)流程。

最后線程池判斷整個(gè)線程池是否已滿？沒滿，則創(chuàng)建一個(gè)新的工作線程來執(zhí)行任務(wù)，滿了，則交給飽和策略來處理這個(gè)任務(wù)。

線程池的創(chuàng)建

我們可以通過ThreadPoolExecutor來創(chuàng)建一個(gè)線程池。

new ThreadPoolExecutor(corePoolSize, maximumPoolSize,

keepAliveTime, milliseconds,runnableTaskQueue, threadFactory,handler);

創(chuàng)建一個(gè)線程池需要輸入幾個(gè)參數(shù)：

corePoolSize - 線程池核心池的大小。

maximumPoolSize - 線程池的最大線程數(shù)。

keepAliveTime - 當(dāng)線程數(shù)大于核心時(shí)，此為終止前多余的空閑線程等待新任務(wù)的最長(zhǎng)時(shí)間。

unit - keepAliveTime 的時(shí)間單位。

workQueue - 用來儲(chǔ)存等待執(zhí)行任務(wù)的隊(duì)列。

threadFactory - 線程工廠。

handler - 拒絕策略。

corePoolSize(線程池的基本大小)

當(dāng)提交一個(gè)任務(wù)到線程池時(shí)，線程池會(huì)創(chuàng)建一個(gè)線程來執(zhí)行任務(wù)，即使其他空閑的基本線程能夠執(zhí)行新任務(wù)也會(huì)創(chuàng)建線程，等到需要執(zhí)行的任務(wù)數(shù)大于線程池基本大小時(shí)就不再創(chuàng)建。如果調(diào)用了線程池的prestartAllCoreThreads方法，線程池會(huì)提前創(chuàng)建并啟動(dòng)所有基本線程。

maximumPoolSize(線程池最大大小)：

線程池允許創(chuàng)建的最大線程數(shù)。如果隊(duì)列滿了，并且已創(chuàng)建的線程數(shù)小于最大線程數(shù)，則線程池會(huì)再創(chuàng)建新的線程執(zhí)行任務(wù)。值得注意的是如果使用了無界的任務(wù)隊(duì)列這個(gè)參數(shù)就沒什么效果。

keepAliveTime(線程活動(dòng)保持時(shí)間)

線程池的工作線程空閑后，保持存活的時(shí)間。所以如果任務(wù)很多，并且每個(gè)任務(wù)執(zhí)行的時(shí)間比較短，可以調(diào)大這個(gè)時(shí)間，提高線程的利用率。

TimeUnit(線程活動(dòng)保持時(shí)間的單位)：可選的單位有天(DAYS)，小時(shí)(HOURS)，分鐘(MINUTES)，毫秒(MILLISECONDS)，微秒(MICROSECONDS, 千分之一毫秒)和毫微秒(NANOSECONDS, 千分之一微秒)。

runnableTaskQueue(任務(wù)隊(duì)列)

用于保存等待執(zhí)行的任務(wù)的阻塞隊(duì)列。可以選擇以下幾個(gè)阻塞隊(duì)列。

ArrayBlockingQueue

是一個(gè)基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列，此隊(duì)列按 FIFO(先進(jìn)先出)原則對(duì)元素進(jìn)行排序。

LinkedBlockingQueue

一個(gè)基于鏈表結(jié)構(gòu)的阻塞隊(duì)列，此隊(duì)列按FIFO (先進(jìn)先出) 排序元素，吞吐量通常要高于ArrayBlockingQueue。靜態(tài)工廠方法Executors.newFixedThreadPool()使用了這個(gè)隊(duì)列。

SynchronousQueue

一個(gè)不存儲(chǔ)元素的阻塞隊(duì)列。每個(gè)插入操作必須等到另一個(gè)線程調(diào)用移除操作，否則插入操作一直處于阻塞狀態(tài)，吞吐量通常要高于LinkedBlockingQueue，靜態(tài)工廠方法Executors.newCachedThreadPool使用了這個(gè)隊(duì)列。

PriorityBlockingQueue

一個(gè)支持優(yōu)先級(jí)排序的無界阻塞隊(duì)列。

DelayQueue

一個(gè)使用優(yōu)先級(jí)隊(duì)列實(shí)現(xiàn)的無界阻塞隊(duì)列。

ThreadFactory

用于設(shè)置創(chuàng)建線程的工廠，可以通過線程工廠給每個(gè)創(chuàng)建出來的線程設(shè)置更有意義的名字，Debug和定位問題時(shí)非常有幫助。

RejectedExecutionHandler(飽和策略)

當(dāng)隊(duì)列和線程池都滿了，說明線程池處于飽和狀態(tài)，那么必須采取一種策略處理提交的新任務(wù)。這個(gè)策略默認(rèn)情況下是AbortPolicy，表示無法處理新任務(wù)時(shí)拋出異常。以下是JDK1.5提供的四種策略。

ThreadPoolExecutor.AbortPolicy: 丟棄任務(wù)并拋出RejectedExecutionException異常。 (默認(rèn))

ThreadPoolExecutor.DiscardPolicy：也是丟棄任務(wù)，但是不拋出異常。

ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊(duì)列最前面的任務(wù)，然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過程)

ThreadPoolExecutor.CallerRunsPolicy：由調(diào)用線程處理該任務(wù)

當(dāng)然也可以根據(jù)應(yīng)用場(chǎng)景需要來實(shí)現(xiàn)RejectedExecutionHandler接口自定義策略。如記錄日志或持久化不能處理的任務(wù)。

線程池不允許使用Executors去創(chuàng)建

線程池不允許使用Executors去創(chuàng)建，而是通過ThreadPoolExecutor的方式，這樣的處理方式讓寫的同學(xué)更加明確線程池的運(yùn)行規(guī)則，規(guī)避資源耗盡的風(fēng)險(xiǎn)。 說明：Executors各個(gè)方法的弊端：

1)newFixedThreadPool和newSingleThreadExecutor

主要問題是堆積的請(qǐng)求處理隊(duì)列可能會(huì)耗費(fèi)非常大的內(nèi)存，甚至OOM。

newSingleThreadExecutor

創(chuàng)建一個(gè)單線程的線程池。這個(gè)線程池只有一個(gè)線程在工作，也就是相當(dāng)于單線程串行執(zhí)行所有任務(wù)。如果這個(gè)唯一的線程因?yàn)楫惓＝Y(jié)束，那么會(huì)有一個(gè)新的線程來替代它。

此線程池保證所有任務(wù)的執(zhí)行順序，按照任務(wù)的提交順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行。

newFixedThreadPool

創(chuàng)建固定大小的線程池。每次提交一個(gè)任務(wù)就創(chuàng)建一個(gè)線程，直到線程達(dá)到線程池的最大大小。

線程池的大小一旦達(dá)到最大值就會(huì)保持不變，如果某個(gè)線程因?yàn)閳?zhí)行異常而結(jié)束，那么線程池會(huì)補(bǔ)充一個(gè)新線程。

可控制線程最大并發(fā)數(shù)，超出的線程會(huì)在隊(duì)列中等待

2)newCachedThreadPool和newScheduledThreadPool

主要問題是線程數(shù)最大數(shù)是Integer.MAX_VALUE，可能會(huì)創(chuàng)建數(shù)量非常多的線程，甚至OOM。

newCachedThreadPool

創(chuàng)建一個(gè)可緩存的線程池。如果線程池的大小超過了處理任務(wù)所需要的線程，

那么就會(huì)回收部分空閑(60秒不執(zhí)行任務(wù))的線程，當(dāng)任務(wù)數(shù)增加時(shí)，此線程池又可以智能的添加新線程來處理任務(wù)。

此線程池不會(huì)對(duì)線程池大小做限制

線程池大小完全依賴于操作系統(tǒng)(或者說JVM)能夠創(chuàng)建的最大線程大小。

newScheduledThreadPool

創(chuàng)建一個(gè)定時(shí)線程池，支持定時(shí)及周期性任務(wù)執(zhí)行

線程池創(chuàng)建方式(推薦)

根據(jù)阿里巴巴java開發(fā)規(guī)范，推薦了3種線程池創(chuàng)建方式

推薦方式1：

首先引入：commons-lang3包

推薦方式 2：

首先引入：com.google.guava包

推薦方式 3：

spring配置線程池方式：自定義線程工廠bean需要實(shí)現(xiàn)ThreadFactory，可參考該接口的其它默認(rèn)實(shí)現(xiàn)類，使用方式直接注入bean

調(diào)用execute(Runnable task)方法即可

總結(jié)

以上是生活随笔為你收集整理的linkedblockingqueue使用_阿里规范要求不能使用Executors创建线程的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。