之前專案要實現一個多執行緒發簡訊的功能，每個執行緒都對應一個kafka消費topic，但是偶爾會由於傳過來的資料或是資料庫的原因發生異常，之前為了專案趕進度都是用的try,catch捕獲的Exception異常直接處理掉了，最近有時間了感覺這樣很low，也很不專業，所以想重構一下程式碼，也上網查了很多資料（網上很多資料都是捕獲異常後直接new Thread().start()，但是專案要求動態啟動異常執行緒，直接new肯定是不合理的，也不滿足需求的），買了關於多執行緒的書，最後決定用執行緒自帶的未捕獲異常類這個方案。

       之前遇到問題都是在網上查的，學習了很多網上的大神的成果，這是我的第二篇部落格，我希望我慢慢也可以有自己的獨立思考體系。

       好了，下面我來講講這個功能實現的過程，如有不足請大家指正！

最初是想建立一個能容納7個執行緒的執行緒池，再給執行緒池配置一個執行緒工廠，執行緒工程負責給執行緒池中的執行緒配置異常捕獲物件，異常捕獲物件裡面再配置執行緒池，直接將傳過來的執行緒放進執行緒池進行重啟。

執行緒池配置：

執行緒工廠配置：

異常捕獲類配置：

經過週末兩天的糾結，最後終於想出了一個方案，由於每個執行緒是一個消費者執行緒，對應接收一個topic的資料，因此將topic作為一個引數先傳給執行緒工廠物件，執行緒工廠再傳給異常捕獲物件，這樣就能在異常捕獲類中根據不同的topic啟動不同的執行緒了。但是這裡面涉及到一個問題，

我們每次對執行緒池中執行緒工廠的操作都是在操作同一個執行緒工廠物件，導致後續測試的時候會出現紊亂的情況，就是明明出現異常的是執行緒1，但是執行緒工廠傳給異常捕獲物件的topic卻是最後一個提交給執行緒池的執行緒7的名稱，導致異常訊息是執行緒1的，重新啟動的卻是執行緒7，為了解決這個問題，只能建立7個newSingleThreadExecutor執行緒池，這樣7個執行緒，對應7個執行緒池，7個執行緒工廠，7個異常捕獲物件，每個都是單獨的一套，就不會出現紊亂了。修改之後的方案配置如下：

執行緒池配置：

customerFactory負責建立Runnable任務。

執行緒工廠配置：

異常捕獲類配置：

經過驗證目前為止還沒出現任何問題。

當然還有另外一種方法，就是不用執行緒池，也不用執行緒工廠，直接給每個執行緒配置未捕獲異常物件：

這樣當然也可以，只是第一種方式可擴充套件性比較大，後續如果一個topic想開多個執行緒，那麼執行緒池就可以進行擴充套件，執行緒工廠也可以對執行緒進行一些別的加工動作。

以上就是我的一些總結，對於上面提到的兩個執行緒池比較深刻的問題，後續等我完全研究明白了，會自動更新的。