你不知道的執行緒池構造方法的那些趣事?
(手機橫屏看原始碼更方便)
注:java原始碼分析部分如無特殊說明均基於 java8 版本。
簡介
ThreadPoolExecutor的構造方法是建立執行緒池的入口,雖然比較簡單,但是資訊量很大,由此也能引發一系列的問題,同樣地,這也是面試中經常被問到的問題,下面彤哥只是列舉了一部分關於ThreadPoolExecutor構造方法的問題,如果你都能回答上來,則可以不用看下面的分析了。
問題
(1)ThreadPoolExecutor有幾個構造方法?
(2)ThreadPoolExecutor最長的構造方法有幾個引數?
(3)keepAliveTime是做什麼用的?
(7)核心執行緒會不會超時關閉?能不能超時關閉?
(4)ConcurrentLinkedQueue能不能作為任務佇列的引數?
(5)預設的執行緒是怎麼建立的?
(6)如何實現自己的執行緒工廠?
(7)拒絕策略有哪些?
(8)預設的拒絕策略是什麼?
構造方法
好了,我們直接上程式碼。
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), defaultHandler); } public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, defaultHandler); } public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), handler); } public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) { if (corePoolSize < 0 || maximumPoolSize <= 0 || maximumPoolSize < corePoolSize || keepAliveTime < 0) throw new IllegalArgumentException(); if (workQueue == null || threadFactory == null || handler == null) throw new NullPointerException(); this.acc = System.getSecurityManager() == null ? null : AccessController.getContext(); this.corePoolSize = corePoolSize; this.maximumPoolSize = maximumPoolSize; this.workQueue = workQueue; this.keepAliveTime = unit.toNanos(keepAliveTime); this.threadFactory = threadFactory; this.handler = handler; }
ThreadPoolExecutor有四個構造方法,其中前三個最終都是呼叫最後一個,它有7個引數,分別為corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory、handler。
corePoolSize
核心執行緒數。
當正在執行的執行緒數小於核心執行緒數時,來一個任務就建立一個核心執行緒;
當正在執行的執行緒數大於或等於核心執行緒數時,任務來了先不建立執行緒而是丟到任務佇列中。
maximumPoolSize
最大執行緒數。
當任務佇列滿了時【本篇文章由公眾號“彤哥讀原始碼”原創】,來一個任務才建立一個非核心執行緒,但不能超過最大執行緒數。
keepAliveTime + unit
執行緒保持空閒時間及單位。
預設情況下,此兩引數僅當正在執行的執行緒數大於核心執行緒數時才有效,即只針對非核心執行緒。
但是,如果allowCoreThreadTimeOut被設定成了true,針對核心執行緒也有效。
即當任務佇列為空時,執行緒保持多久才會銷燬,內部主要是通過阻塞佇列帶超時的poll(timeout, unit)方法實現的。
workQueue
任務佇列。
當正在執行的執行緒數大於或等於核心執行緒數時,任務來了是先進入任務佇列中的。
這個佇列必須是阻塞佇列,所以像ConcurrentLinkedQueue就不能作為引數,因為它雖然是併發安全的佇列,但是它不是阻塞佇列。
// ConcurrentLinkedQueue並沒有實現BlockingQueue介面
public class ConcurrentLinkedQueue<E> extends AbstractQueue<E>
implements Queue<E>, java.io.Serializable {
// ...【本篇文章由公眾號“彤哥讀原始碼”原創】
}
threadFactory
執行緒工廠。
預設使用的是Executors工具類中的DefaultThreadFactory類,這個類有個缺點,建立的執行緒的名稱是自動生成的,無法自定義以區分不同的執行緒池,且它們都是非守護執行緒。
static class DefaultThreadFactory implements ThreadFactory {
private static final AtomicInteger poolNumber = new AtomicInteger(1);
private final ThreadGroup group;
private final AtomicInteger threadNumber = new AtomicInteger(1);
private final String namePrefix;
DefaultThreadFactory() {
SecurityManager s = System.getSecurityManager();
group = (s != null) ? s.getThreadGroup() :
Thread.currentThread().getThreadGroup();
namePrefix = "pool-" +
poolNumber.getAndIncrement() +
"-thread-";
}
public Thread newThread(Runnable r) {
Thread t = new Thread(group, r,
namePrefix + threadNumber.getAndIncrement(),
0);
if (t.isDaemon())
t.setDaemon(false);
if (t.getPriority() != Thread.NORM_PRIORITY)
t.setPriority(Thread.NORM_PRIORITY);
return t;
}
}
那怎麼自定義一個執行緒工廠呢?
其實也很簡單,自己實現一個ThreadFactory,然後把名稱和是否是守護程序當作構造方法的引數傳進來就可以了。
有興趣的同學可以參考netty中的預設執行緒工廠或者google中的執行緒工廠。
io.netty.util.concurrent.DefaultThreadFactory
com.google.common.util.concurrent.ThreadFactoryBuilder
handler
拒絕策略。
拒絕策略表示當任務佇列滿了且執行緒數也達到最大了,這時候再新加任務,執行緒池已經無法承受了,這些新來的任務應該按什麼邏輯來處理。
常用的拒絕策略有丟棄當前任務、丟棄最老的任務、丟擲異常、呼叫者自己處理等待。
預設的拒絕策略是丟擲異常,即執行緒池無法承載了,呼叫者再往裡面新增任務會丟擲異常。
預設的拒絕策略雖然比較簡單粗暴,但是相對於丟棄任務策略明顯要好很多,最起碼呼叫者自己可以捕獲這個異常再進行二次處理。
彩蛋
OK,ThreadPoolExecutor的構造方法這塊我們今天進行了深入解析,關於這塊,您還有什麼問題呢?歡迎留言評論、私聊勾搭。
歡迎關注我的公眾號“彤哥讀原始碼”,檢視更多原始碼系列文章, 與彤哥一起暢遊原始碼的海洋。