不久之前，部門進行了一次代碼評審。

代碼整體比較簡單，該吹B的地方都已經吹過了，無非是些if else的老問題而已。當翻到一段定時任務的一步執行代碼時，我的雙眼一亮，覺得該BB兩句了。

誰知這群家伙，評審的時候滿滿的認同感，但評審結束不久，就給我冠了個事B的稱號。

今天我就把當時的這些話兒整理整理，讓大家說道說道，我到底是不是個事B。淦！

一個任務處理例子

代碼的結構大體是這樣的。

通過定時，這段代碼每天晚上凌晨都要對數據庫的記錄進行一遍對賬。主要的邏輯，就是使用獨立的線程，漸進式的讀取數據庫中的相關記錄，然后把這些記錄，放在循環中逐條進行處理。

ExecutorService?service?=?Executors.newFixedThreadPool(10); ... service.submit(()->{while(true){if(CollectionUtils.isEmpty(items)){break;}List<Data>?items?=?queryPageData(start,?end);?//?分頁邏輯for(Data?item?:?items){try?{Thread.sleep(10L);}?catch?(InterruptedException?e)?{//noop?}processItem(item);}} });

等一下。在代碼馬上被翻過去的時候，我叫停了，這里的processItem沒有捕獲異常。

通常情況下，這不會有什么問題。但靜好的歲月，總是偶爾會被一些隨機的事故打斷。如果這是你任務的完整代碼，那它就有一種非常隱晦的故障處理方式。即使你的單元測試寫的再好，這段代碼我們依然可以通過遠程投毒的方式，通過問題記錄來讓它產生問題。

是的。以上代碼的根本原因，就是沒有捕捉processItem函數可能產生的異常。如果在記錄處理的時候，有任何一條拋出了異常，不管是checked異常還是unchecked異常，整個任務的執行都會終止！

不要覺得簡單哦，踩過這個坑的同學，請記得扣個666?；蛘叻幌履愕娜蝿請绦写a，看看是不是也有這個問題。

Java編譯器在很多情況下都會提示你把異常給捕捉了，但總有些異常會逃出去，比如空指針異常。如下圖，RuntimeException和Error都屬于unchecked異常。

RuntimeException可以不用try...catch進行處理，但是如果一旦出現異常，則會導致程序中斷執行，JVM將統一處理這些異常。

你捕捉不到它，它自然會讓你的任務完蛋。

如果你想要異步的執行一些任務，最好多花一點功夫到異常設計上面。在這上面翻車的同學比比皆是，這輛車并不介意再帶上你一個。

評審的小伙很謙虛，馬上就現場修改了代碼。

不要生吞異常

且看修改后的代碼。

ExecutorService?service?=?Executors.newFixedThreadPool(10); ... service.submit(()->{while(true){if(CollectionUtils.isEmpty(items)){break;}List<Data>?items?=?queryPageData(start,?end);?//?分頁邏輯for(Data?item?:?items){try?{Thread.sleep(10L);}?catch?(InterruptedException?e)?{//noop?}try{processItem(item);}catch(Exception?ex){LOG.error(...,ex);}}} }); ... service.shutdownNow();

為了控制任務執行的頻率，sleep大法是個有效的方法。

代碼里考慮的很周到，按照我們上述的方式捕捉了異常。同時，還很貼心的把sleep相關的異常也給捕捉了。這里不貼心也沒辦法，因為不補齊這部分代碼的話，編譯無法通過，我們姑且認為是開發人員的水平夠屌。

由于sleep拋出的是InterruptedException，所以代碼什么也沒處理。這也是我們代碼里常見的操作。不信打開你的項目，忽略InterruptedException的代碼肯定多如牛毛。

此時，你去執行這段代碼，雖然線程池使用了暴力的shutdownNow函數，但你的代碼依然無法終止，它將一直run下去。因為你忽略了InterruptedException異常。

當然，我們可以在捕捉到InterruptedException的時候，終止循環。

try?{Thread.sleep(10L); }?catch?(InterruptedException?e)?{break; }

雖然這樣能夠完成預期，但一般InterruptedException卻不是這么處理的。正確的處理方式是這樣的：

while?(true)?{Thread?currentThread?=?Thread.currentThread();if(currentThread.isInterrupted()){break;}try?{Thread.sleep(1L);}?catch?(InterruptedException?e)?{currentThread.interrupt();} }

除了捕捉它，我們還要再次把interrupt狀態給復位，否則它就隨著捕捉給清除了。InterruptedException在很多場景非常的重要。當有些方法一直阻塞著線程，比如耗時的計算，會讓整個線程卡在那里什么都干不了，InterruptedException可以中斷任務的執行，是非常有用的。

但是對我們現在代碼的邏輯來說，并沒有什么影響。被評審的小伙伴不滿意的說。

還有問題！

有沒有影響是一回事，是不是好的習慣是另一回事?。我盡量的裝了一下B，其實，你的異常處理代碼里還有另外隱藏的問題。

還有什么問題？，大家都一改常日慵懶的表情，你倒是說說。

我們來看一下小伙伴現場改的問題。他直接使用catch捕獲了這里的異常，然后記錄了相應的日志。我要說的問題是，這里的Exception粒度是不對的，太粗魯。

try{processItem(item); }catch(Exception?ex){LOG.error(...,ex); }

processItem函數拋出了IOException，同時也拋出了InterruptedException，但我們都一致對待為普通的Exception，這樣就無法體現上層函數拋出異常的意圖。

比如processItem函數拋出了一個TimeoutExcepiton，期望我們能夠基于它做一些重試；或者拋出了SystemBusyExcption，期望我們能夠多sleep一會，給服務器一點時間。這種粗粒度的異常一股腦的將它們捕捉，在新異常添加的時候根本無法發現這些代碼，會發生風險。

一時間會議室里寂靜無比。

我覺得你說的很對?，一位比較資深的老鳥說，?你的意思是把所有的異常情況都分別捕捉，進行精細化處理。但最后你還是要使用Exception來捕捉RuntimeException，異常還是捕捉不到啊。

果然是不同凡響的發問。

優秀的、標準的代碼寫法，其中無法實施的一個重要因素，就是項目中的其他代碼根本不按規矩來。如果我們下層的代碼，進行了正確的空指針判斷、數組越界操作，或者使用類似guava的Preconditions這類API進行了前置的異常翻譯，上面的這種問題根本不用回答。

但上面這種代碼的情況，我們就需要手動的捕捉RuntimeException，進行單獨的處理。

你們這個項目，爛代碼太多了，所以不好改。我雖然有情商，但我更有脾氣。

大家不歡而散。

End

我實在是想不通，代碼review就是用來發現問題的。結果這review會一開下來，大家都在背后諷刺我。這到底是我的問題呢？還是這個團隊的問題呢？讓人搞不懂。

你們在糾結使用Integer還是int的時候，我也沒說什么呀，現在就談點異常處理的問題，就那么玻璃心受不了了。這B不能全都讓你們裝了啊。

什么？你要review一下我的代碼？看看我到底有沒有像我說的一樣寫代碼，有沒有以身作則？是在不好意思，我可是架構師哎，我已經很多年沒寫代碼了。

你的這個愿望讓你落空了！

完

往期推薦

輕量級動態線程池才是“王道”？

synchronized 底層了解一下...

如何抓到入侵網站的黑客？

有道無術，術可成；有術無道，止于術

歡迎大家關注Java之道公眾號

好文章，我在看??

總結

以上是生活随笔為你收集整理的代码review，瑞出事来了！的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。