xylz,imxylz

Java中線程執(zhí)行的任務(wù)接口java.lang.Runnable 要求不拋出Checked異常，

public interface Runnable {

    public abstract void run();
}

那么如果 run() 方法中拋出了RuntimeException，將會怎么處理了？

通常java.lang.Thread對象運(yùn)行設(shè)置一個(gè)默認(rèn)的異常處理方法：

java.lang.Thread.setDefaultUncaughtExceptionHandler(UncaughtExceptionHandler)

而這個(gè)默認(rèn)的靜態(tài)全局的異常捕獲方法時(shí)輸出堆棧。

當(dāng)然，我們可以覆蓋此默認(rèn)實(shí)現(xiàn)，只需要一個(gè)自定義的java.lang.Thread.UncaughtExceptionHandler接口實(shí)現(xiàn)即可。

public interface UncaughtExceptionHandler {

    void uncaughtException(Thread t, Throwable e);
}

而在線程池中卻比較特殊。默認(rèn)情況下，線程池 java.util.concurrent.ThreadPoolExecutor 會Catch住所有異常， 當(dāng)任務(wù)執(zhí)行完成(java.util.concurrent.ExecutorService.submit(Callable))獲取其結(jié)果 時(shí)(java.util.concurrent.Future.get())會拋出此RuntimeException。

/**
 * Waits if necessary for the computation to complete, and then
 * retrieves its result.
 *
 * @return the computed result
 * @throws CancellationException if the computation was cancelled
 * @throws ExecutionException if the computation threw an exception
 * @throws InterruptedException if the current thread was interrupted while waiting
 */
V get() throws InterruptedException, ExecutionException;

其中 ExecutionException 異常即是java.lang.Runnable 或者 java.util.concurrent.Callable 拋出的異常。

也就是說，線程池在執(zhí)行任務(wù)時(shí)捕獲了所有異常，并將此異常加入結(jié)果中。這樣一來線程池中的所有線程都將無法捕獲到拋出的異常。 從而無法通過設(shè)置線程的默認(rèn)捕獲方法攔截的錯(cuò)誤異常。

也不同通過自定義線程來完成異常的攔截。

好在java.util.concurrent.ThreadPoolExecutor 預(yù)留了一個(gè)方法，運(yùn)行在任務(wù)執(zhí)行完畢進(jìn)行擴(kuò)展（當(dāng)然也預(yù)留一個(gè)protected方法beforeExecute(Thread t, Runnable r)）：

protected void afterExecute(Runnable r, Throwable t) { } 

此方法的默認(rèn)實(shí)現(xiàn)為空，這樣我們就可以通過繼承或者覆蓋ThreadPoolExecutor 來達(dá)到自定義的錯(cuò)誤處理。

解決辦法如下：

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(11, 100, 1, TimeUnit.MINUTES, //
        new ArrayBlockingQueue<Runnable>(10000),//
        new DefaultThreadFactory()) {

    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        printException(r, t);
    }
};

private static void printException(Runnable r, Throwable t) {
    if (t == null && r instanceof Future<?>) {
        try {
            Future<?> future = (Future<?>) r;
            if (future.isDone())
                future.get();
        } catch (CancellationException ce) {
            t = ce;
        } catch (ExecutionException ee) {
            t = ee.getCause();
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt(); // ignore/reset
        }
    }
    if (t != null)
        log.error(t.getMessage(), t);
}

此辦法的關(guān)鍵在于，事實(shí)上 afterExecute 并不會總是拋出異常 Throwable t，通過查看源碼得知，異常是封裝在此時(shí)的Future對象中的， 而此Future對象其實(shí)是一個(gè)java.util.concurrent.FutureTask的實(shí)現(xiàn)，默認(rèn)的run方法其實(shí)調(diào)用的 java.util.concurrent.FutureTask.Sync.innerRun()。

這里我們可以看到它吃掉了異常，將異常存儲在java.util.concurrent.FutureTask.Sync的exception字段中：

/** The exception to throw from get() */
private Throwable exception;

當(dāng)我們獲取異步執(zhí)行的結(jié)果時(shí)， java.util.concurrent.FutureTask.get()

public V get() throws InterruptedException, ExecutionException {
    return sync.innerGet();
}

java.util.concurrent.FutureTask.Sync.innerGet()

V innerGet() throws InterruptedException, ExecutionException {
    acquireSharedInterruptibly(0);
    if (getState() == CANCELLED)
        throw new CancellationException();
    if (exception != null)
        throw new ExecutionException(exception);
    return result;
}

異常就會被包裝成ExecutionException異常拋出。

也就是說當(dāng)我們想線程池 ThreadPoolExecutor(java.util.concurrent.ExecutorService)提交任務(wù)時(shí)， 如果不理會任務(wù)結(jié)果（Feture.get()），那么此異常將被線程池吃掉。

<T> Future<T> submit(Callable<T> task);
Future<?> submit(Runnable task);

而java.util.concurrent.ScheduledThreadPoolExecutor是繼承ThreadPoolExecutor的，因此情況類似。

結(jié)論，通過覆蓋ThreadPoolExecutor.afterExecute 方法，我們才能捕獲到任務(wù)的異常（RuntimeException）。

原文地址：http://imxylz.com/blog/2013/08/02/handling-the-uncaught-exception-of-java-thread-pool/