1 基础
Java提供的Thread需要写一堆的代码，用了spring，想让哪个方法是异步的，加个注解，就搞定了。
spring AOP，会主动拦截添加注解@Scheduled/@Async的方法，然后，由spring维护线程的整个生命周期。
- 定时任务@Schedule
@Scheduled(cron = "0/20 * * * * ?") //每20秒执行一次
- 异步任务@Async
释义：开启异步任务，执行标记的方法。方法看起来还是普通的方法，但是呢，调用的时候，spring会主动开启新的线程。
思考：如果，开启的线程数量太多，服务器处理不完，怎么办？
答：类似jdbc的Connection。同样的道理，创建一个线程池，需要线程的时候，从池子里租出来，用完再放回去；得不到服务的线程，不能直接丢弃，还需要再维护一个任务队列；如果排队的任务超出了队列的范围，那就得考虑扩容了，调参、或是多加台服务器、或者直接拒绝。
2 进阶：共用一个Thread Pool
| method上添加的注解 | Thread Pool class | configuaration |
|---|---|---|
| @Schedule | ThreadPoolTaskScheduler | @EnableScheduling |
| @Async | ThreadPoolTaskExecutor | @EnableAsync |
2.1 配置bean
@Configuration //添加这个注解的class，只在容器启动的时候加载一次
@EnableAsync //启用异步任务：TaskExecutor
@EnableScheduling //启用定时任务：TaskScheduler
public class CommonBeanConfigure {
@Bean("asyncExecutor") //指定TaskExecutor 的bean name
public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
threadPoolTaskExecutor.setCorePoolSize(10);
threadPoolTaskExecutor.setMaxPoolSize(20);
threadPoolTaskExecutor.setQueueCapacity(1000);
threadPoolTaskExecutor.setThreadNamePrefix("async-t-");
return threadPoolTaskExecutor;
}
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setThreadNamePrefix("p-scheduler-");
scheduler.setPoolSize(10);
return scheduler;
}
}
2.2 配置需要开启多线程的method
@Async("asyncExecutor") //指定TaskExecutor 的bean name
public void refreshOnlineUser(OAuth2Authentication auth2Authentication){...}
@Scheduled(cron = "0/20 * * * * ?") //每隔20秒执行一次
public void count() {...}
2.3 测试
请注意“ThreadNamePrefix”，如果打印出来的日志里，thread name没有预设的前缀，那么，配置的这个bean TaskExecutor 或 TaskScheduler 就没有生效（这两个线程的前缀不同）
此时，请检查@Async、@Scheduled。不需要对比所有的配置文件，最快的解决方案：
- 配置TaskExecutor 或 TaskScheduler 时，设置bean name；
- 同时，指定@Async、@Scheduled使用的bean name
3 异常处理
异步任务的异常，不会让主线程停止运行。（应该的，本来就不在一个线程里）
当然，凡事都有例外，比如，分布式事务的“其中一种机制”补偿机制，与这种情况类似。当异步任务抛异常后，通知main Thread使用“补偿措施”回滚事务。
请参考http://blog.csdn.net/blueheart20/article/details/44648667
目前，还没有这样的需求，所以，不建议使用这种“重型”的解决方案
4 补充描述
4.1 线程的名字没有预设的前缀
首先，能看到线程的名字，说明在方法上添加的注解生效了；其次，预定的前缀没有打印出来，那就说明bean的配置，没有生效。
一句话，spring根据方法上的注解，使用默认的实现类创建了线程，没有使用配置的Thread pool。
解决方案：
- 设置bean的name。eg.
@Bean("asyncTask")
public TaskExecutor taskExecutor()
- 指定方法使用的bean name。 eg.
@Async("asyncTask")
public void hello()
4.2 什么样的class、method可以使用@Async、@Scheduled
开启异步任务、定时任务，只跟method有关。每次调用这些method的时候，spring上下文都会开启新的线程。
所以，任何一个method都可以添加@Async、@Scheduled。
注意：这两个注解必须放在实现类的方法上，如果，放在interface的方法声明上，不会生效的。
错误示例：
public interface UserLoginHistoryService {
//每晚12点清理日志 --- 这个定时任务不会执行的，因为，标记在interface的方法声明上了
@Scheduled(cron = "0 0 0 * * ?")
void deleteHistory();
}
4.3 为什么必须指定TaskExecutor的bean name?
网上可以找到很多帖子，说是@Async没有生效。据说是有其他的配置覆盖了（没找到...）。所以，我猜测，应该是spring的BUG。
解决办法：指定TaskExecutor 的name
4.4 @EnableAsync、@EnableScheduling
这两个注解是用来通知spring 容器，尝试加载相关的bean，启用异步任务或定时任务。所以，一个项目里，只需要在任意一个@Configuaration标记的class上，添加这两个注解即可。
当然，规范些，还是在配置bean TaskExecutor 、TaskScheduler 的class上，添加@EnableAsync 、@EnableScheduling
注：不能滥用注解。虽然，多次配置，也不会报错，但，多余的配置，会造成误解。
4.5 当预设的线程用完了
线程池中配置的线程是有数的，当用完了，程序或者是等待，或者，不处理。死活都要撑着，只能让服务器崩溃。这种情况，主要针对的是TaskExecutor （通常，一个项目中TaskScheduler 定时任务是有限的）。
1、允许等待的线程，本身处理的任务，耗时要少些。再配合QueueCapacity队列，可以最大限度地保障系统高效地运行（能处理的任务，快速处理完，然后，归还线程；不能处理的任务，先排队，轮到了，再处理）；
2、直接拒绝的线程，应该是那些本身就要耗时很长，超出服务器处理能力的请求。或者拒绝，或者，多加几台服务器
当然，也可以适当增加线程的数量，这个，得考虑硬件条件
4.6 守护线程
web应用跑在JVM上，线程也跑在JVM上，严格说起来，咱们new Thread()跟web应用没关系。换句话说，关闭web应用后，某些线程还在继续运行。
如果你使用我的配置方案启用Async/Schedule，spring容器会自动管理这些线程。当web应用关闭后，相关的线程也会stop。
详细的原理，请查阅“守护线程”
