首先我们需要了解其规则——@Async有两个限制：
必须仅应用在public方法上自执行——从相同类中调用异步方法不起作用。原因很简单——public方法能够被代理，自执行不工作是因为它绕过代理并直接调用底层方法。
处理调整报 Executor [java.util.concurrent.ThreadPoolExecutor@2b045d98[Running, pool size = 200, active threads = 1, queued tasks = 420, completed tasks = 244874312]] did not accept task: org.springframework.aop.interceptor.AsyncExecutionInterceptor$1@4f9ae398 @Configuration @ComponentScan("com.xxx.xxx.biz.*.*Service") @EnableAsync public class ThreadConfig extends AsyncConfigurerSupport{ @Override public ThreadPoolTaskExecutor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 核心池的大小（即线程池中的线程数目大于这个参数时，提交的任务会被放进任务缓存队列） executor.setCorePoolSize(50); // 线程池最大能容忍的线程数 executor.setMaxPoolSize(500); // 任务缓存队列，用来存放等待执行的任务 executor.setQueueCapacity(800); executor.setWaitForTasksToCompleteOnShutdown(true); // 线程池维护线程所允许的空闲时间 executor.setAwaitTerminationSeconds(60 * 30); executor.setThreadNamePrefix("xxx-xxx-thread-"); // 线程池对拒绝任务(无线程可用)的处理策略 ThreadPoolExecutor.CallerRunsPolicy策略 ,调用者的线程会执行该任务,如果执行器已关闭,则丢弃. executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.initialize(); return executor; } @Override public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { return new AsyncUncaughtExceptionHandler() { @Override public void handleUncaughtException(Throwable throwable, Method method, Object... objects) { log.warn("ThreadConfig处理异步常异-->{},{}",method.getName(),objects,throwable); } }; } } 在ThreadPoolExecutor中表现为: 如果当前运行的线程数小于corePoolSize，那么就创建线程来执行任务（执行时需要获取全局锁）。 如果运行的线程大于或等于corePoolSize，那么就把task加入BlockQueue。 如果创建的线程数量大于BlockQueue的最大容量，那么创建新线程来执行该任务。 如果创建线程导致当前运行的线程数超过maximumPoolSize，就根据饱和策略来拒绝该任务。
