Loading...
墨滴

wistchen

2021/04/05  阅读:33  主题:前端之巅同款

线程池在项目中运用的心得体会

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注解

wistchen

2021/04/05  阅读:33  主题:前端之巅同款

作者介绍

wistchen