处理来自Java ExecutorService任务的异常

处理来自Java ExecutorService任务的异常

提交Runnable时，它将被包装在Future中。

你的afterExecute应该是这样的：

public final class ExtendedExecutor extends ThreadPoolExecutor {    // ...    protected void afterExecute(Runnable r, Throwable t) {        super.afterExecute(r, 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(); }        }        if (t != null) { System.out.println(t);        }    }}