项目中使用线程池的心得总结

Posted 2021-04-23 小陈同学爱生活

1 线程池在项目中的运用总结

1.1 背景

工作中，用到线程池的地方是同步人员工作量的功能，该功能是选择时间同步人员工作量，工作量来自禅道系统+Digiprocess 系统。

正常是发起工作量请求，业务逻辑处理，响应入库。这样存在一个很大的弊端就是多了一次请求别的系统的数据+数据库操作，进而可能会导致响应速度较慢。

使用线程池，将同步方法放入队列中，然后直接返回响应，会极大的提高接口的响应速度。

1.2 线程池的作用

• 线程复用
• 线程资源管理
• 控制操作系统的最大并发数、以保证系统高效且安全的运行

1.3 线程池核心参数

• corePoolSize 线程池中核心的线程数量
• maxmumPoolSize 线程池最大线程池的数量
• keepAliveTime 当线程超过 corePoolSize，多余的空闲线程的存活时间
• unit KeepAliveTime 的单位
• workQueue 任务队列
• threadFactory 线程工厂
• handler 拒绝策略，队列满了，并且工作线程大于等于线程池的最大线程数

1.4 工作原理

1.5 三种重要的线程池

• newFixedThreadPool 固定大小线程池，执行长期的任务
• newSingleThreadExecutor 单个线程的线程池
• newCachedTreadPool 可缓存的线程池 适用于短期任务

1.6 JDK 内置的拒绝策略

• AbortPolicy 直接抛出rejectedExecutionException 异常阻止系统正常运行
• CallerRunsPolicy 不会丢弃任务，将某些任务回调到调用者
• DiscarOldPolicy 抛弃队列中等待最久的任务，然后把当前任务加入队列
• DiscarPolicy 直接丢弃任务

2 SpringBoot线程池的创建

2.1 启动类配置

在SpringBoot的主程序中配置@EnableAsync

2.2 配置

@EnableAsync
@Configuration
public class TaskPoolConfig {
    /** 
 *   默认情况下，在创建了线程池后，线程池中的线程数为0，当有任务来之后，就会创建一个线程去执行任务，
 *    当线程池中的线程数目达到corePoolSize后，就会把到达的任务放到缓存队列当中；
 *  当队列满了，就继续创建线程，当线程数量大于等于maxPoolSize后，开始使用拒绝策略拒绝 
 */
   @Value("${task.pool.corePoolSize}")
   private Integer corePoolSize;//设置核心线程数
   @Value("${task.pool.maxPoolSize}")
   private Integer maxPoolSize;//设置最大线程数
   @Value("${task.pool.keepAliveSeconds}")
   private Integer keepAliveSeconds;//设置线程活跃时间（秒）
   @Value("${task.pool.queueCapacity}")
   private Integer queueCapacity;//设置队列容量
   
   @Bean("taskExecutor")
   public Executor taskExecutor() {
      //创建一个线程池
      ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
      // 核心线程数10：线程池创建时候初始化的线程数
      executor.setCorePoolSize(corePoolSize);
      // 最大线程数20：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程
      executor.setMaxPoolSize(maxPoolSize);
      // 缓冲队列200：用来缓冲执行任务的队列
      executor.setQueueCapacity(queueCapacity);
      // 允许线程的空闲时间60秒：当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
      executor.setKeepAliveSeconds(keepAliveSeconds);
      // 线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池
      executor.setThreadNamePrefix("taskExecutor-");
      // 线程池对拒绝任务的处理策略：
      // 这里采用了CallerRunsPolicy策略，当线程池没有处理能力的时候，
      // 该策略会直接在 execute 方法的调用线程中运行被拒绝的任务；
      // 如果执行程序已关闭，则会丢弃该任务
      executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
      return executor;
   }
}
@Async会默认从线程池获取线程，当然也可以显式的指定@Async("asyncTaskExecutor")

2.3 properties配置

### 线程池
task.pool.corePoolSize=10
task.pool.maxPoolSize=20
task.pool.keepAliveSeconds=60
task.pool.queueCapacity=200

2.4 注意事项

如下方式会使@Async失效

• 异步方法使用static修饰
• 异步类没有使用@Component注解（或其他注解）导致spring无法扫描到异步类
• 异步方法不能与被调用的异步方法在同一个类中
• 类中需要使用@Autowired或@Resource等注解自动注入，不能自己手动new对象
• 如果使用SpringBoot框架必须在启动类中增加@EnableAsync注解