AsyncConfigurerSupport自定义异步线程池处理异常

@Service
public class ServiceA{
   public void testA(){
       testB();
   }
   @Async
   public void testB(){
   }
}

@Configuration
@EnableAsync
public class AsyncConfigHandler extends AsyncConfigurerSupport {
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(10);
        executor.initialize();
        return executor;
    }
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new MyAsyncUncaughtExceptionHandler();
    }
    @Bean   // /actuator/shutdown
    @Override
    public Executor getAsyncExecutor2() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setTaskDecorator(new SomeTaskDecorator());
        executor.setCorePoolSize(4);
        executor.setMaxPoolSize(8);
        executor.setQueueCapacity(100);
        executor.setAllowCoreThreadTimeOut(false);
        executor.setKeepAliveSeconds(0);
        executor.setThreadNamePrefix("DefaultAsync-");
        executor.setWaitForTasksToCompleteOnShutdown(true); // 다 끝날때까지 대기
        executor.initialize();
        return executor;
    }
    static class SomeTaskDecorator implements TaskDecorator {
        @Override
        public Runnable decorate(Runnable runnable) {
            return () -> {
                try {
                    log.info("Some Task Decorator Start");
                    runnable.run();
                } finally {
                    log.info("Some Task Decorator End");
                }
            };
        }
    }
}
class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {
    @Override
    public void handleUncaughtException(Throwable ex, Method method, Object... params) {
        System.out.println("class#method: " + method.getDeclaringClass().getName() + "#" + method.getName());
        System.out.println("type        : " + ex.getClass().getName());
        System.out.println("exception   : " + ex.getMessage());
    }
}

@Service
public class DemoService {
    @Async
    public void testAsync() throws InterruptedException {
        System.out.println("这里是异步方法");
        TimeUnit.SECONDS.sleep(10);
        int i = 1 / 0;
    }
}

@RestController
@RequestMapping(value = "time")
public class DemoController {
    @Autowired
    private DemoService demoService;
    @RequestMapping(value = "getTimeAndAsync")
    public String getTimeAndAsync() throws InterruptedException {
        demoService.testAsync();
        return "异步加载=》" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
    }
}