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沒有捕獲異常。

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

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

不要覺得簡單哦，踩過這個坑的同學，請記得扣個666?；蛘叻幌履愕娜蝿?wù)執(zhí)行代碼，看看是不是也有這個問題。

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

RuntimeException可以不用try...catch進行處理，但是如果一旦出現(xiàn)異常，則會導致程序中斷執(zhí)行，JVM將統(tǒng)一處理這些異常。

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

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

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

不要生吞異常

且看修改后的代碼。

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();

為了控制任務(wù)執(zhí)行的頻率，sleep大法是個有效的方法。

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

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

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

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

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

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

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

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

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

還有問題！

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

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

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

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

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

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

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

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

果然是不同凡響的發(fā)問。

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

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

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

大家不歡而散。