你是否已經準備好跳槽了呢，是否期望自己拿到更高的薪資呢，是否有望獲得心儀的offer呢!那么，今天這套Java面試題是你不二之選，本篇題目總結了在各大一線互聯網公司面試官的出題經驗，深剖核心問題，多角度的去挖掘后，為大呈現出來的：

資源回收

考慮到系統資源是有限的，對于線程池超出 corePoolSize 數量的空閑線程應進行回收操作。進行此操作存在一個問題，即回收時機。目前的實現方式是當線程空閑時間超過 keepAliveTime 后，進行回收。除了核心線程數之外的線程可以進行回收，核心線程內的空閑線程也可以進行回收。回收的前提是allowCoreThreadTimeOut屬性被設置為 true，通過public void allowCoreThreadTimeOut(boolean) 方法可以設置屬性值。

排隊策略

如 3.1.2 線程創建規則一節中規則 2 所說，當線程數量大于等于 corePoolSize，workQueue 未滿時，則緩存新任務。這里要考慮使用什么類型的容器緩存新任務，通過 JDK 文檔介紹，我們可知道有 3 中類型的容器可供使用，分別是同步隊列，有界隊列和無界隊列。對于有優先級的任務，這里還可以增加優先級隊列。以上所介紹的 4 中類型的隊列，對應的實現類如下：

| 實現類 | 類型 | 說明 |

| --- | --- | --- |

| SynchronousQueue | 同步隊列 | 該隊列不存儲元素，每個插入操作必須等待另一個線程調用移除操作，否則插入操作會一直阻塞 |

| ArrayBlockingQueue | 有界隊列 | 基于數組的阻塞隊列，按照 FIFO 原則對元素進行排序 |

| LinkedBlockingQueue | 無界隊列 | 基于鏈表的阻塞隊列，按照 FIFO 原則對元素進行排序 |

| PriorityBlockingQueue | 優先級隊列 | 具有優先級的阻塞隊列 |

拒絕策略

如 3.1.2 線程創建規則一節中規則 4 所說，線程數量大于等于 maximumPoolSize，且 workQueue 已滿，則使用拒絕策略處理新任務。Java 線程池提供了 4 中拒絕策略實現類，如下：

| 實現類 | 說明 |

| --- | --- |

| AbortPolicy | 丟棄新任務，并拋出?RejectedExecutionException |

| DiscardPolicy | 不做任何操作，直接丟棄新任務 |

| DiscardOldestPolicy | 丟棄隊列隊首的元素，并執行新任務 |

| CallerRunsPolicy | 由調用線程執行新任務 |

以上 4 個拒絕策略中，AbortPolicy 是線程池實現類所使用的策略。我們也可以通過方法public void setRejectedExecutionHandler(RejectedExecutionHandler)修改線程池決絕策略。

線程的創建與復用

在線程池的實現上，線程的創建是通過線程工廠接口ThreadFactory的實現類來完成的。默認情況下，線程池使用Executors.defaultThreadFactory()方法返回的線程工廠實現類。當然，我們也可以通過

public void setThreadFactory(ThreadFactory)方法進行動態修改。具體細節這里就不多說了，并不復雜，大家可以自己去看下源碼。

在線程池中，線程的復用是線程池的關鍵所在。這就要求線程在執行完一個任務后，不能立即退出。對應到具體實現上，工作線程在執行完一個任務后，會再次到任務隊列獲取新的任務。如果任務隊列中沒有任務，且 keepAliveTime 也未被設置，工作線程則會被一致阻塞下去。通過這種方式即可實現線程復用。

說完原理，再來看看線程的創建和復用的相關代碼(基于 JDK 1.8)，如下：

`+----ThreadPoolExecutor.Worker.java Worker(Runnable firstTask) {


setState(-1);


this.firstTask = firstTask;


// 調用線程工廠創建線程


this.thread = getThreadFactory().newThread(this);


}


// Worker 實現了 Runnable 接口


public void run() {


runWorker(this);


}


+----ThreadPoolExecutor.java final void runWorker(Worker w) {


Thread wt = Thread.currentThread();


Runnable task = w.firstTask;


w.firstTask = null;


w.unlock();


boolean completedAbruptly = true;


try {


// 循環從任務隊列中獲取新任務


while (task != null || (task = getTask()) != null) {


w.lock();


// If pool is stopping, ensure thread is interrupted;


// if not, ensure thread is not interrupted.  This


// requires a recheck in second case to deal with


// shutdownNow race while clearing interrupt


if ((runStateAtLeast(ctl.get(), STOP) ||


(Thread.interrupted() &&


runStateAtLeast(ctl.get(), STOP))) &&


!wt.isInterrupted())


wt.interrupt();


try {


beforeExecute(wt, task);


Throwable thrown = null;


try {


// 執行新任務


task.run();


} catch (RuntimeException x) {


thrown = x; throw x;


} catch (Error x) {


thrown = x; throw x;


} catch (Throwable x) {


thrown = x; throw new Error(x);


} finally {


afterExecute(task, thrown);


}


} finally {


task = null;


w.completedTasks++;


w.unlock();


}


}


completedAbruptly = false;


} finally {


// 線程退出后，進行后續處理


processWorkerExit(w, completedAbruptly);


}


}`

以上就是“一線大廠總結出的Java項目經理面試題”，你能回答上來嗎?如果想要了解更多的Java面試題相關內容，可以關注動力節點Java官網。