1.为什么要给@Async自定义线程池 @Async注解，在默认情况用的是SimpleAsyncTaskExecutor线程池，该线程池不会重用，每次调用都会新建一条现场。在日志输出查看，每次打印的线程名都是【task-1】，【task-2】…递增的。
SimpleAsyncTaskExecutor：不是真的线程池，这个类不重用线程，每次调用都会创建一个新的线程。SyncTaskExecutor：这个类没有实现异步调用，只是一个同步操作。只适用于不需要多线程的地方ConcurrentTaskExecutor：Executor的适配类，不推荐使用。如果ThreadPoolTaskExecutor不满足要求时，才用考虑使用这个类SimpleThreadPoolTaskExecutor：是Quartz的SimpleThreadPool的类。线程池同时被quartz和非quartz使用，才需要使用此类ThreadPoolTaskExecutor ：最常使用，推荐。 其实质是对java.util.concurrent.ThreadPoolExecutor的包装2.为@Async自定义一个线程池，配置线程池
@Configuration @EnableAsync public class SyncConfiguration { @Bean(name = "scorePoolTaskExecutor") public ThreadPoolTaskExecutor getScorePollTaskExecutor() { ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor(); //核心线程数 taskExecutor.setCorePoolSize(10); //线程池维护的最大数量 taskExecutor.setMaxPoolSize(100); //空闲时间，超过该事件会被销毁 taskExecutor.setKeepAliveSeconds(200); //异步方法内部线程名称 taskExecutor.setThreadNamePrefix("score-"); /** *当线程池的任务缓存队列已满，且线程池中线程数目达到MaxPoolSize，如果还有任务来 * 就会采取任务拒绝策略 * 通常有一下4种策略： *拒绝策略，分4种，AbortPolicy直接抛出异常 * DiscardPolicy悄悄抛弃不执行 * CallerRunsPolicy（调用者运行）：该策略既不会抛弃任务也不会抛出异常，而是将这个任务退回给调用者，从而降低新任务的流量； * DiscardOldestPolicy（抛弃最旧的） */ taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); taskExecutor.initialize(); return taskExecutor; } }3.为@Async配置线程池名字
@Async("scorePoolTaskExecutor") public void addScore2() { try { Thread.sleep(1000*5); log.info("--------------处理积分--------------"); }catch (InternalError | InterruptedException ex) { ex.printStackTrace(); } }