java - 发生异常时停止 ThreadPoolTask​​Executor

Question

当抛出未捕获的异常时是否可以停止org.springframework.scheduling.concurrent.ThreadPoolTask​​Executor，以及如何做到这一点？

例如，当抛出 MyCustomException 时，我想停止线程并在主线程中捕获异常:

taskExecutor.execute(new Runnable() {
    @Override
    public void run() {
        try {
            int i = 1/0;
        } catch (Exception e) {
            throw new MyCustomException(e);
        }
    }
});

Answer 1

由于您使用的是匿名内部类，因此这应该足够了:

taskExecutor.execute(new Runnable() {
    @Override
    public void run() {
        try {
            int i = 1/0;
        } catch (Exception e) {
            onExceptionInTask( new MyCustomException(e) ); // <== Inform main.
        }
    }
});

这是对“主”类中的方法的调用:

protected void onExceptionInTask( MyCustomException e ){
    // do your thing like stop all tasks ... 
}