本文引用自:

http://blog.chinaunix.net/uid-20577907-id-3519578.html?

?

一、簡(jiǎn)介?
線程池類為 java.util.concurrent.ThreadPoolExecutor，常用構(gòu)造方法為：?

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,?long keepAliveTime, TimeUnit unit,?BlockingQueue?workQueue,?RejectedExecutionHandler handler)?
corePoolSize： 線程池維護(hù)線程的最少數(shù)量?
maximumPoolSize：線程池維護(hù)線程的最大數(shù)量?
keepAliveTime： 線程池維護(hù)線程所允許的空閑時(shí)間?
unit： 線程池維護(hù)線程所允許的空閑時(shí)間的單位?
workQueue： 線程池所使用的緩沖隊(duì)列?
handler： 線程池對(duì)拒絕任務(wù)的處理策略?

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

當(dāng)一個(gè)任務(wù)通過(guò)execute(Runnable)方法欲添加到線程池時(shí)：?
如果此時(shí)線程池中的數(shù)量小于corePoolSize，即使線程池中的線程都處于空閑狀態(tài)，也要?jiǎng)?chuàng)建新的線程來(lái)處理被添加的任務(wù)。?
如果此時(shí)線程池中的數(shù)量等于 corePoolSize，但是緩沖隊(duì)列 workQueue未滿，那么任務(wù)被放入緩沖隊(duì)列。?
如果此時(shí)線程池中的數(shù)量大于corePoolSize，緩沖隊(duì)列workQueue滿，并且線程池中的數(shù)量小于maximumPoolSize，建新的線程來(lái)處理被添加的任務(wù)。?
如果此時(shí)線程池中的數(shù)量大于corePoolSize，緩沖隊(duì)列workQueue滿，并且線程池中的數(shù)量等于maximumPoolSize，那么通過(guò) handler所指定的策略來(lái)處理此任務(wù)。?

?

也就是：處理任務(wù)的優(yōu)先級(jí)為：?
核心線程corePoolSize、任務(wù)隊(duì)列workQueue、最大線程maximumPoolSize，如果三者都滿了，使用handler處理被拒絕的任務(wù)。?

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

unit可選的參數(shù)為java.util.concurrent.TimeUnit中的幾個(gè)靜態(tài)屬性：?NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS。?

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

handler有四個(gè)選擇：?
ThreadPoolExecutor.AbortPolicy()?
拋出java.util.concurrent.RejectedExecutionException異常?
ThreadPoolExecutor.CallerRunsPolicy()?
重試添加當(dāng)前的任務(wù)，他會(huì)自動(dòng)重復(fù)調(diào)用execute()方法?
ThreadPoolExecutor.DiscardOldestPolicy()?
拋棄舊的任務(wù)?
ThreadPoolExecutor.DiscardPolicy()?
拋棄當(dāng)前的任務(wù)?

?

二、一般用法舉例?

1 import java.io.Serializable; 2 import java.util.concurrent.ArrayBlockingQueue; 3 import java.util.concurrent.ThreadPoolExecutor; 4 import java.util.concurrent.TimeUnit; 5 6 public class TestThreadPool { 7 8 private static int produceTaskSleepTime = 2; 9 10 private static int produceTaskMaxNumber = 10; 11 12 public static void main(String[] args) { 13 // 構(gòu)造一個(gè)線程池 14 ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(3), 15 new ThreadPoolExecutor.DiscardOldestPolicy()); 16 // corePoolSize： 線程池維護(hù)線程的最少數(shù)量 ==============>2 17 // maximumPoolSize：線程池維護(hù)線程的最大數(shù)量 ==============>4 18 // keepAliveTime： 線程池維護(hù)線程所允許的空閑時(shí)間 ==============>3 19 // unit： 線程池維護(hù)線程所允許的空閑時(shí)間的單位 ==============>TimeUnit.SECONDS 20 // workQueue： 線程池所使用的緩沖隊(duì)列 ==============>new ArrayBlockingQueue<Runnable>(3) 21 // handler： 線程池對(duì)拒絕任務(wù)的處理策略 ==============>new ThreadPoolExecutor.DiscardOldestPolicy() 22 23 for (int i = 1; i <= produceTaskMaxNumber; i++) { 24 try { 25 // 產(chǎn)生一個(gè)任務(wù)，并將其加入到線程池 26 String task = "task@ " + i; 27 System.out.println("put " + task); 28 threadPool.execute(new ThreadPoolTask(task)); 29 30 // 便于觀察，等待一段時(shí)間 31 Thread.sleep(produceTaskSleepTime); 32 } catch (Exception e) { 33 e.printStackTrace(); 34 } 35 } 36 } 37 } 38 39 /** 40 * 線程池執(zhí)行的任務(wù) 41 */ 42 class ThreadPoolTask implements Runnable, Serializable { 43 44 private static final long serialVersionUID = 0; 45 46 private static int consumeTaskSleepTime = 2000; 47 48 // 保存任務(wù)所需要的數(shù)據(jù) 49 private Object threadPoolTaskData; 50 51 ThreadPoolTask(Object tasks) { 52 this.threadPoolTaskData = tasks; 53 } 54 55 public void run() { 56 // 處理一個(gè)任務(wù)，這里的處理方式太簡(jiǎn)單了，僅僅是一個(gè)打印語(yǔ)句 57 System.out.println(Thread.currentThread().getName()); 58 System.out.println("start .." + threadPoolTaskData); 59 60 try { 61 //便于觀察，等待一段時(shí)間 62 Thread.sleep(consumeTaskSleepTime); 63 } catch (Exception e) { 64 e.printStackTrace(); 65 } 66 threadPoolTaskData = null; 67 } 68 69 public Object getTask() { 70 return this.threadPoolTaskData; 71 } 72 }

?

說(shuō)明：?
1、在這段程序中，一個(gè)任務(wù)就是一個(gè)Runnable類型的對(duì)象，也就是一個(gè)ThreadPoolTask類型的對(duì)象。?
2、一般來(lái)說(shuō)任務(wù)除了處理方式外，還需要處理的數(shù)據(jù)，處理的數(shù)據(jù)通過(guò)構(gòu)造方法傳給任務(wù)。?
3、在這段程序中，main()方法相當(dāng)于一個(gè)殘忍的領(lǐng)導(dǎo)，他派發(fā)出許多任務(wù)，丟給一個(gè)叫 threadPool的任勞任怨的小組來(lái)做。?
這個(gè)小組里面隊(duì)員至少有兩個(gè)，如果他們兩個(gè)忙不過(guò)來(lái)，任務(wù)就被放到任務(wù)列表里面。?
如果積壓的任務(wù)過(guò)多，多到任務(wù)列表都裝不下(超過(guò)3個(gè))的時(shí)候，就雇傭新的隊(duì)員來(lái)幫忙。但是基于成本的考慮，不能雇傭太多的隊(duì)員，至多只能雇傭 4個(gè)。?
如果四個(gè)隊(duì)員都在忙時(shí)，再有新的任務(wù)，這個(gè)小組就處理不了了，任務(wù)就會(huì)被通過(guò)一種策略來(lái)處理，我們的處理方式是不停的派發(fā)，直到接受這個(gè)任務(wù)為止(更殘忍！呵呵)。?
因?yàn)殛?duì)員工作是需要成本的，如果工作很閑，閑到 3SECONDS都沒有新的任務(wù)了，那么有的隊(duì)員就會(huì)被解雇了，但是，為了小組的正常運(yùn)轉(zhuǎn)，即使工作再閑，小組的隊(duì)員也不能少于兩個(gè)。?
4、通過(guò)調(diào)整 produceTaskSleepTime和 consumeTaskSleepTime的大小來(lái)實(shí)現(xiàn)對(duì)派發(fā)任務(wù)和處理任務(wù)的速度的控制，改變這兩個(gè)值就可以觀察不同速率下程序的工作情況。?
5、通過(guò)調(diào)整4中所指的數(shù)據(jù)，再加上調(diào)整任務(wù)丟棄策略，換上其他三種策略，就可以看出不同策略下的不同處理方式。?
6、對(duì)于其他的使用方法，參看jdk的幫助，很容易理解和使用。?

?

另一個(gè)例子:?

1 import java.util.Queue; 2 import java.util.concurrent.ArrayBlockingQueue; 3 import java.util.concurrent.ThreadPoolExecutor; 4 import java.util.concurrent.TimeUnit; 5 6 public class ThreadPoolExecutorTest { 7 8 private static int queueDeep = 4; 9 10 public void createThreadPool() { 11 /* 12 * 創(chuàng)建線程池，最小線程數(shù)為2，最大線程數(shù)為4，線程池維護(hù)線程的空閑時(shí)間為3秒， 使用隊(duì)列深度為4的有界隊(duì)列，如果執(zhí)行程序尚未關(guān)閉，則位于工作隊(duì)列頭部的任務(wù)將被刪除， 13 * 然后重試執(zhí)行程序（如果再次失敗，則重復(fù)此過(guò)程），里面已經(jīng)根據(jù)隊(duì)列深度對(duì)任務(wù)加載進(jìn)行了控制。 14 */ 15 ThreadPoolExecutor tpe = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueDeep), 16 new ThreadPoolExecutor.DiscardOldestPolicy()); 17 18 // 向線程池中添加 10 個(gè)任務(wù) 19 for (int i = 0; i < 10; i++) { 20 try { 21 Thread.sleep(1); 22 } catch (InterruptedException e) { 23 e.printStackTrace(); 24 } 25 while (getQueueSize(tpe.getQueue()) >= queueDeep) { 26 System.out.println("隊(duì)列已滿，等3秒再添加任務(wù)"); 27 try { 28 Thread.sleep(3000); 29 } catch (InterruptedException e) { 30 e.printStackTrace(); 31 } 32 } 33 TaskThreadPool ttp = new TaskThreadPool(i); 34 System.out.println("put i:" + i); 35 tpe.execute(ttp); 36 } 37 38 tpe.shutdown(); 39 } 40 41 private synchronized int getQueueSize(Queue queue) { 42 return queue.size(); 43 } 44 45 public static void main(String[] args) { 46 ThreadPoolExecutorTest test = new ThreadPoolExecutorTest(); 47 test.createThreadPool(); 48 } 49 50 class TaskThreadPool implements Runnable { 51 52 private int index; 53 54 public TaskThreadPool(int index) { 55 this.index = index; 56 } 57 58 public void run() { 59 System.out.println(Thread.currentThread() + " index:" + index); 60 try { 61 Thread.sleep(3000); 62 } catch (InterruptedException e) { 63 e.printStackTrace(); 64 } 65 } 66 } 67 }

?

轉(zhuǎn)載于:https://www.cnblogs.com/DreamDrive/p/4758260.html

總結(jié)

以上是生活随笔為你收集整理的关于线程池ThreadPoolExecutor使用总结的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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