线程池

2017-11-23 本文已影响163人惊世一饿

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。

详细的原理，请查阅“守护线程”

线程池