### ThreadPoolExecutor ``` public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler); ``` * **corePoolSize** 線程池中的核心線程數，當提交一個任務時，線程池創建一個新線程執行任務，直到當前線程數等于corePoolSize；如果當前線程數為corePoolSize，繼續提交的任務被保存到阻塞隊列中，等待被執行；如果執行了線程池的prestartAllCoreThreads\(\)方法，線程池會提前創建并啟動所有核心線程； * **maximumPoolSize** 線程池中允許的最大線程數。如果當前阻塞隊列滿了，且繼續提交任務，則創建新的線程執行任務，前提是當前線程數小于maximumPoolSize； * **keepAliveTime** 線程空閑時的存活時間，即當線程沒有任務執行時，繼續存活的時間；默認情況下，該參數只在線程數大于corePoolSize時才有用； * **unit** keepAliveTime的單位； * **workQueue** 用來保存等待被執行的任務的阻塞隊列，且任務必須實現Runable接口，在JDK中提供了如下阻塞隊列： 1. ArrayBlockingQueue：基于數組結構的有界阻塞隊列，按FIFO排序任務； 2. LinkedBlockingQuene：基于鏈表結構的阻塞隊列，按FIFO排序任務，吞吐量通常要高于ArrayBlockingQuene； 3. SynchronousQuene：一個不存儲元素的阻塞隊列，每個插入操作必須等到另一個線程調用移除操作，否則插入操作一直處于阻塞狀態，吞吐量通常要高于LinkedBlockingQuene； 4. priorityBlockingQuene：具有優先級的無界阻塞隊列； * **threadFactory** 創建線程的工廠，通過自定義的線程工廠可以給每個新建的線程設置一個具有識別度的線程名 ``` 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; } } ``` 知識點 * maximumPoolSize不能小于corePoolSize * Executors.newFixedThreadPool\(\); corePoolSize = maximumPoolSize 運行原理： 1. 當線程池線程數小于corePoolSize時，新提交任務將創建一個新線程執行任務，即使此時線程池中存在空閑線程； 2. 當線程池達到corePoolSize時，新提交任務將被放入workQueue中，等待線程池中任務調度執行； 3. 當workQueue已滿，且maximumPoolSize&gt;corePoolSize時，新提交任務會創建新線程執行任務； 4. 當提交任務數超過maximumPoolSize時，新提交任務由RejectedExecutionHandler處理； 5. 當線程池中線程超過corePoolSize線程，且線程空閑時間達到keepAliveTime時，關閉空閑線程； 6. 當設置allowCoreThreadTimeOut\(true\)時，線程池中corePoolSize線程空閑時間達到keepAliveTime也將關閉； 實例： 并不是先加入任務就一定會先執行。假設隊列大小為 10，corePoolSize 為 3，maximumPoolSize 為 6，那么當加入 20 個任務時，執行的順序就是這樣的：首先執行任務 1、2、3，然后任務 4~13 被放入隊列。這時候隊列滿了，任務 14、15、16 會被馬上執行，而任務 17~20 則會拋出異常。最終順序是：1、2、3、14、15、16、4、5、6、7、8、9、10、11、12、13 流程圖：