三：執行緒池的相關總結

1.執行緒池的意義：

執行緒雖然好用，但是如果建立了大量的執行緒，會拖垮整個程式，甚至可能會出現OOM異常；另一方面，大量的執行緒被GC的時候，也會產生巨大的壓力，延長GC的停頓時間。

其次，執行緒在被建立和銷燬的時候，也是會消耗系統的記憶體和資源的。

說的簡單一點，你們JDBC連線是不是用連線池的，現在基本上不會有人去建立JDBC連線，然後去使用它了，基本都是利用連線池，取得池內的連線。執行緒池也是一樣的概念。我們不再建立執行緒，而是從執行緒池中去取得，由執行緒池去控制和管理執行緒。

2.最基本的執行緒池：

JDK對於多執行緒的控制，專門提供了一套Executor

1）newFixedThreadPool：構造方法時必須傳入執行緒數（Int），這是一個固定傳入引數的執行緒數的執行緒池

2）newSingleThreadPool：這是一個固定只有一個執行緒的執行緒池

3）newCacheThreadPool：這是一個最大執行緒數無上限的執行緒池

這三個執行緒池，看似功能不同，但是其實他們都是ThreadPoolExecutor類的封裝，我們可以看一下，關於這個ThreadPoolExecutor

最完整的構造方法裡面構造引數有7個，分別是corePoolSize，maximumPoolSize，keepActiveTime，unit，workQueue，threadFactory，RejectedExecutionHandler。

corePoolSize 表示執行緒池的核心執行緒數，

maximumPoolSize 表示執行緒池最大執行緒數

keepActiveTime 表示線上程池中，空閒執行緒的存活時間

Unit 表示上面存活時間的時間單位

workQueue 表示執行緒池中的任務佇列

threadFactory 表示執行緒池中的執行緒工廠，基本上都是選擇預設的，關於這個東西，阿里雲的程式碼規範對這個執行緒工廠做了一個補充，大家可以去看看

RejectedExecutionHandler 表示的是這個執行緒池中的拒絕策略，JDK預設的拒絕策略是AbortPolicy

我覺得知道了連線池，再去看執行緒池，其實都是差不多的，所以什麼核心執行緒數，最大執行緒數，存活時間的我就不多說了，覺得可以說一下的是workQueue和RejectedExecutionHandler。

一般來說，任務佇列（workQueue）有以下的幾種，

1.SynchronousQueue（直接提交佇列），這個任務佇列，他沒有容量，基本就是屬於有了任務，就將任務提交給執行緒池，讓執行緒池建立新的執行緒，直至執行緒池中的活躍執行緒大於最大執行緒數，這個時候，執行緒池就直接執行拒絕策略（RejectedExecutionHandler）

2.ArrayBlockingQueue（有界佇列），如果要使用這個任務佇列，就必須在初始化的時候，傳入容量引數，代表這個任務佇列的最大容量。對於這個任務佇列而言，當執行緒池中的活躍執行緒數等於核心執行緒數之後，這個佇列就不提交任務了，直到任務堆積過多，超過了容量引數，這個時候，任務佇列才會繼續提交任務，讓執行緒池開始生成新的執行緒，直到活躍執行緒數大於最大執行緒數，而這個時候，執行緒池就開始執行拒絕策略了

3.LinkedBlockingQueue（無界佇列），這個佇列，他的容量是無限的，他可以不斷的增長，直到吃完系統的所有資源。對於這個佇列而言，當執行緒池中的活躍執行緒數等於核心執行緒數之後，他也同樣不會提交任務，但是和有界佇列不同，因為他的容量是無限的，所以不存在會使用最大執行緒數的時候，也不存在拒絕策略，除非你的系統先掛掉

4.PriorityBlockingQueue（優先佇列），這個佇列，是一個特殊的無界佇列，所以在對待執行緒池內的執行緒數的控制方面，是和無界佇列一致的。對於有界佇列和無界佇列而言，他們其實都是按照先進先算，後進後算的方法來向執行緒池傳遞任務的。但是優先佇列正如名字一樣，他是會根據任務自己的優先順序來決定先後執行順序的。所以換句話說，如果你要使用優先佇列，那麼就要讓你的任務去實現Comparable介面，重寫裡面的compareTo方法，具體可以參考下面的程式碼

package com.liu.javathread.priorityblockingqueue;

public class MyThread implements Runnable, Comparable<MyThread>{

	protected String name;

	public MyThread(String name) {
		super();
		this.name = name;
	}

	public MyThread() {
		
	}

	@Override
	public int compareTo(MyThread o) {
		// 這是自身這個執行緒的數值
		int me = Integer.parseInt(this.name.split("_")[1]);
		// 傳參的執行緒的資料
		int other = Integer.parseInt(o.name.split("_")[1]);
		if(me > other){
			return 1;
		}else if(me < other){
			return -1;
		}else{
			return 0;
		}
	}

	@Override
	public void run() {
		try {
			// 系統沉睡模擬工作任務
			Thread.sleep(1000);
			System.out.println(name+" ");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	
	
}

package com.liu.javathread.priorityblockingqueue;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class MyThreadMain {

	public static void main(String[] args) {
		
		ExecutorService executor = new ThreadPoolExecutor(10, 100, 2, TimeUnit.SECONDS, new PriorityBlockingQueue<Runnable>());
		for(int i=0;i<1000;i++){
			executor.execute(new MyThread("testThread_"+Integer.toString(999-i)));
		}
	}

}

而關於拒絕策略，我覺得一般來說，選擇預設的AbortPolicy就可以了，這個拒絕策略意思是直接丟擲異常，阻止系統繼續工作

另外的拒絕策略，CallerRunsPolicy，DiscardOledestPolicy,DiscardPolicy這些策略，大家有興趣可以自己研究一下，另外如果說，你對於這些拒絕策略都不滿意，可以自己去重新實現。RejectedExecutionHandler 這個東西其實他是一個介面，上述的那些都是他的實現。

最後大家可以去看一下，之前我們說的三個JDK定義好的執行緒池，他們的核心執行緒數，最大執行緒數，存活時間，包括任務佇列分別都是些什麼。這對於我們已經選擇JDK自帶的執行緒池有很大的幫助

3.擴充套件執行緒池：

阿里巴巴的程式碼規範中，建議我們使用執行緒池，而且最好不是使用JDK自帶的執行緒池，而是利用最基本的執行緒池ThreadPoolExecutor，不僅僅是因為我們可以自由的選擇任務佇列，拒絕策略，更多的是因為，這個執行緒池具有可擴充套件性

首先具體的來說，最具代表性的就是beforeExecutor()和afterExecutor()這兩個方法，這兩個方法看方法名就知道，他們分別是線上程池內執行緒啟動之前和執行緒結束之後分別去呼叫的。

我們可以通過繼承ThreadPoolExecutor這個類，然後重寫這兩個方法，去實現我們的業務，我個人覺得這個在除錯的時候比較有用，至少你可以知道你的多個執行緒在執行前和執行後的狀態。具體可以參考MyThreadPool這個檔案。另外如果大家有興趣的話，可以去找一下為什麼執行緒池內部在呼叫工作執行緒的時候，會呼叫這兩個方法