這篇文章將為大家詳細(xì)講解有關(guān)ThreadPoolExecutor該如何解析，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。

成都創(chuàng)新互聯(lián)專注于漢陰網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠為您提供漢陰營銷型網(wǎng)站建設(shè)，漢陰網(wǎng)站制作、漢陰網(wǎng)頁設(shè)計(jì)、漢陰網(wǎng)站官網(wǎng)定制、小程序開發(fā)服務(wù)，打造漢陰網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供漢陰網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

線程池類為 java.util.concurrent.ThreadPoolExecutor，常用構(gòu)造方法為：

ThreadPoolExecutor(intcorePoolSize, int maximumPoolSize,

longkeepAliveTime,  TimeUnit unit,  BlockingQueueworkQueue, 

RejectedExecutionHandlerhandler)

corePoolSize：線程池維護(hù)線程的最少數(shù)量

maximumPoolSize：線程池維護(hù)線程的最大數(shù)量

keepAliveTime：線程池維護(hù)線程所允許的空閑時間

unit：線程池維護(hù)線程所允許的空閑時間的單位

workQueue：線程池所使用的緩沖隊(duì)列

handler：線程池對拒絕任務(wù)的處理策略

一個任務(wù)通過 execute(Runnable)方法被添加到線程池，任務(wù)就是一個 Runnable類型的對象，任務(wù)的執(zhí)行方法就是 Runnable類型對象的run()方法。

當(dāng)一個任務(wù)通過execute(Runnable)方法欲添加到線程池時：

1、如果此時線程池中的數(shù)量小于corePoolSize，即使線程池中的線程都處于空閑狀態(tài)，也要創(chuàng)建新的線程來處理被添加的任務(wù)。

2、如果此時線程池中的數(shù)量等于 corePoolSize，但是緩沖隊(duì)列workQueue未滿，那么任務(wù)被放入緩沖隊(duì)列。

3、如果此時線程池中的數(shù)量大于corePoolSize，緩沖隊(duì)列workQueue滿，并且線程池中的數(shù)量小于maximumPoolSize，建新的線程來處理被添加的任務(wù)。

4、如果此時線程池中的數(shù)量大于corePoolSize，緩沖隊(duì)列workQueue滿，并且線程池中的數(shù)量等于maximumPoolSize，那么通過handler所指定的策略來處理此任務(wù)。

處理任務(wù)的優(yōu)先級為：

核心線程corePoolSize、任務(wù)隊(duì)列workQueue、最大線程maximumPoolSize，如果三者都滿了，使用handler處理被拒絕的任務(wù)。

當(dāng)線程池中的線程數(shù)量大于 corePoolSize時，如果某線程空閑時間超過keepAliveTime，線程將被終止。這樣線程池可以動態(tài)的調(diào)整池中的線程數(shù)。

unit可選的參數(shù)為java.util.concurrent.TimeUnit中的幾個靜態(tài)屬性：

    NANOSECONDS

    MICROSECONDS

    MILLISECONDS

    SECONDS

workQueue我常用的是：java.util.concurrent.ArrayBlockingQueue

handler有四個選擇：

1、ThreadPoolExecutor.AbortPolicy()

  拋出java.util.concurrent.RejectedExecutionException異常

2、ThreadPoolExecutor.CallerRunsPolicy()

  重試添加當(dāng)前的任務(wù)，他會自動重復(fù)調(diào)用execute()方法

3、ThreadPoolExecutor.DiscardOldestPolicy()

  拋棄舊的任務(wù)

4、ThreadPoolExecutor.DiscardPolicy()

  拋棄當(dāng)前的任務(wù)

例子：

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.ThreadPoolExecutor;

import java.util.concurrent.TimeUnit;

public class TestThreadPool {

private static int produceTaskSleepTime = 2;

private static int produceTaskMaxNumber = 10;

public static void main(String[] args) {

// 構(gòu)造一個線程池

ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS,

new ArrayBlockingQueue(3), new ThreadPoolExecutor.DiscardOldestPolicy());

for (int i = 1; i <= produceTaskMaxNumber; i++) {

try {

// 產(chǎn)生一個任務(wù)，并將其加入到線程池

String task = "task@ " + i;

System.out.println("put " + task);

threadPool.execute(new ThreadPoolTask(task));

// 便于觀察，等待一段時間

Thread.sleep(produceTaskSleepTime);

} catch (Exception e) {

e.printStackTrace();

}

}

}

}

/**

 * 線程池執(zhí)行的任務(wù)

 * 

 */

public class ThreadPoolTask implements Runnable, Serializable {

private static final long serialVersionUID = 0;

// 保存任務(wù)所需要的數(shù)據(jù)

private Object threadPoolTaskData;

ThreadPoolTask(Object tasks) {

this.threadPoolTaskData = tasks;

}

private static int consumeTaskSleepTime = 2000;

public void run() {

// 處理一個任務(wù)，這里的處理方式太簡單了，僅僅是一個打印語句

System.out.println("start .." + threadPoolTaskData);

try {

//// 便于觀察，等待一段時間

Thread.sleep(consumeTaskSleepTime);

} catch (Exception e) {

e.printStackTrace();

}

threadPoolTaskData = null;

}

public Object getTask() {

return this.threadPoolTaskData;

}

}

說明：

1、在這段程序中，一個任務(wù)就是一個Runnable類型的對象，也就是一個ThreadPoolTask類型的對象。

2、一般來說任務(wù)除了處理方式外，還需要處理的數(shù)據(jù)，處理的數(shù)據(jù)通過構(gòu)造方法傳給任務(wù)。

3、在這段程序中，main()方法相當(dāng)于一個殘忍的領(lǐng)導(dǎo)，他派發(fā)出許多任務(wù)，丟給一個叫 threadPool的任勞任怨的小組來做。

這個小組里面隊(duì)員至少有兩個，如果他們兩個忙不過來，任務(wù)就被放到任務(wù)列表里面。

如果積壓的任務(wù)過多，多到任務(wù)列表都裝不下(超過3個)的時候，就雇傭新的隊(duì)員來幫忙。但是基于成本的考慮，不能雇傭太多的隊(duì)員，至多只能雇傭 4個。

如果四個隊(duì)員都在忙時，再有新的任務(wù)，這個小組就處理不了了，任務(wù)就會被通過一種策略來處理，我們的處理方式是不停的派發(fā)，直到接受這個任務(wù)為止(更殘忍！呵呵)。

因?yàn)殛?duì)員工作是需要成本的，如果工作很閑，閑到 3 SECONDS都沒有新的任務(wù)了，那么有的隊(duì)員就會被解雇了，但是為了小組的正常運(yùn)轉(zhuǎn)，即使工作再閑，小組的隊(duì)員也不能少于兩個。

4、通過調(diào)整 produceTaskSleepTime和consumeTaskSleepTime的大小來實(shí)現(xiàn)對派發(fā)任務(wù)和處理任務(wù)的速度的控制，改變這兩個值就可以觀察不同速率下程序的工作情況。

5、通過調(diào)整4中所指的數(shù)據(jù)，再加上調(diào)整任務(wù)丟棄策略，換上其他三種策略，就可以看出不同策略下的不同處理方式。

6、對于其他的使用方法，參看jdk的幫助，很容易理解和使用。

關(guān)于ThreadPoolExecutor該如何解析就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。