SpringBoot中ThreadPoolTaskExecutor的使用

简介: SpringBoot中ThreadPoolTaskExecutor的使用

@[TOC]

1 配置自己的线程池

@Configuration
@EnableAsync
public class ThreadPoolConfig
{
   
    // 核心线程池大小
    private int corePoolSize = 50;

    // 最大可创建的线程数
    private int maxPoolSize = 200;

    // 队列最大长度
    private int queueCapacity = 1000;

    // 线程池维护线程所允许的空闲时间
    private int keepAliveSeconds = 300;

    @Bean(name = "threadPoolTaskExecutor")
    public ThreadPoolTaskExecutor threadPoolTaskExecutor()
    {
   
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置最大线程池数量
        executor.setMaxPoolSize(maxPoolSize);
        // 核心线程数
        executor.setCorePoolSize(corePoolSize);
        // 线程池维护线程所允许的空闲时间
        executor.setKeepAliveSeconds(keepAliveSeconds);
        // 队列最大长度
        executor.setQueueCapacity(queueCapacity);
        // 线程前缀名称
        executor.setThreadNamePrefix("ThreadPoolTaskExecutor======>");
        // 设置线程池关闭时,等待所有任务都完成后,再继续销毁其他的bean
        // 这样这些异步任务的销毁就会优先于 数据库连接池对象的销毁
        // 也就是说当其他bean都完成任务销毁后,数据库连接池对象才会销毁
        executor.setWaitForTasksToCompleteOnShutdown(true);
        // 任务的等待时间,如果超过这个时间还没有销毁,就强制销毁,以确保应用最后能够被关闭,而不是阻塞住
        executor.setAwaitTerminationSeconds(5);
        // 线程池对拒绝任务(无线程可用)的处理策略
        // 线程不够用时由调用的线程处理该任务
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}
  • 一定要自己配置,不要使用SpringBoot自带的,Spring默认的线程池没有上限,并发多时,可能会OOM。并且不是线程重用,每次都会新建一个线程。ThreadPoolTaskExecutor 会重用线程,节省创建线程的资源。因此,在使用ThreadLocal时,也要及时清理缓存,否则,会获取到上一个任务的参数。

    2 使用

    2.1 在Service层使用

  • Controller层直接返回结果,具体的业务,由其他线程执行。
      @Override
      @Async("threadPoolTaskExecutor")
      public void concatAB() {
         
          ......
      }
    

    2.2 多线程中使用事务的写法

  • 事务放到其他方法@Transactional,然后调用。

      @Override
      @Async("threadPoolTaskExecutor")
      public void concatAB() {
         
          addChange()
          ......
      }
    
    @Transactional(rollbackFor = Exception.class,isolation = Isolation.SERIALIZABLE)
      public void addChange(){
         
          .......
      }
    

    2.3 方法内多线程

    2.3.1 错误写法

  • 错误写法

      @Override
      public void concatAB() {
         
          addChange()
          ......
      }
    
      @Async("threadPoolTaskExecutor")
      public void addChange(){
         
          .......
      }
    
  • @Async注解可以让Spring使用线程池来异步执行带有该注解的方法,当一个带有@Async注解的方法被调用时,Spring会为其创建代理对象。通过这个代理对象来调用该方法,Spring就可以控制方法的异步执行了。

  • 如果不是通过代理对象来调用@Async方法,方法的执行将与当前线程同步运行,不会实现异步处理的效果。所以在同一个类中调用加了@Async注解的方法,需要使用代理对象来调用以确保异步生效。

    2.3.2 正确写法(一)

  • 第一种,直接使用线程池执行异步方法。

      @Autowired
      private ThreadPoolTaskExecutor threadPoolTaskExecutor;
    
      @Override
      public void concatAB() {
         
          threadPoolTaskExecutor.execute(() -> {
         
              ....
          });
      }
    

    2.3.2 正确写法(二)

  • 使用代理对象

    @Override
      public void concatAB() {
         
          // 获取代理对象
          IDemoService demoService = (IDemoService) AopContext.currentProxy();
          // 使用代理对象调用
          demoService.addChange()
          ......
      }
    
      @Async("threadPoolTaskExecutor")
      public void addChange(){
         
          .......
      }
    

    2.3.3 正确写法(三)

  • DemoService中通过@Autowired将自身注入到selfProxy属性中,并使用selfProxy对象在syncMethod方法中调用了asyncMethod方法,从而实现了对同一类中的带有@Async注解的方法的异步调用。

    @Autowired
      private DemoService selfProxy;
    
      @Async
      public void asyncMethod() {
         
          // 异步执行的逻辑
      }
    
      public void syncMethod() {
         
          // 调用异步方法需要使用代理对象
          selfProxy.asyncMethod();
      }
    

    3 线程池与并行流的选取

  • IO密集型的业务,选取线程池来完成。(例如,连接数据库之类的操作)
  • cpu密集型的业务,选取并行流allelesvs.parallelStream()的方式处理。(例如,计算类、过滤、求和、分组等)
目录
相关文章
|
Java Spring 容器
Spring boot 自定义ThreadPoolTaskExecutor 线程池并进行异步操作
Spring boot 自定义ThreadPoolTaskExecutor 线程池并进行异步操作
819 3
|
SQL 消息中间件 JavaScript
性能爆表:SpringBoot利用ThreadPoolTaskExecutor批量插入百万级数据实测!
性能爆表:SpringBoot利用ThreadPoolTaskExecutor批量插入百万级数据实测!
|
4月前
|
JavaScript 前端开发 Java
制造业ERP源码,工厂ERP管理系统,前端框架:Vue,后端框架:SpringBoot
这是一套基于SpringBoot+Vue技术栈开发的ERP企业管理系统,采用Java语言与vscode工具。系统涵盖采购/销售、出入库、生产、品质管理等功能,整合客户与供应商数据,支持在线协同和业务全流程管控。同时提供主数据管理、权限控制、工作流审批、报表自定义及打印、在线报表开发和自定义表单功能,助力企业实现高效自动化管理,并通过UniAPP实现移动端支持,满足多场景应用需求。
353 1
|
5月前
|
前端开发 Java 关系型数据库
基于Java+Springboot+Vue开发的鲜花商城管理系统源码+运行
基于Java+Springboot+Vue开发的鲜花商城管理系统(前后端分离),这是一项为大学生课程设计作业而开发的项目。该系统旨在帮助大学生学习并掌握Java编程技能,同时锻炼他们的项目设计与开发能力。通过学习基于Java的鲜花商城管理系统项目,大学生可以在实践中学习和提升自己的能力,为以后的职业发展打下坚实基础。技术学习共同进步
368 7
|
4月前
|
供应链 JavaScript BI
ERP系统源码,基于SpringBoot+Vue+ElementUI+UniAPP开发
这是一款专为小微企业打造的 SaaS ERP 管理系统,基于 SpringBoot+Vue+ElementUI+UniAPP 技术栈开发,帮助企业轻松上云。系统覆盖进销存、采购、销售、生产、财务、品质、OA 办公及 CRM 等核心功能,业务流程清晰且操作简便。支持二次开发与商用,提供自定义界面、审批流配置及灵活报表设计,助力企业高效管理与数字化转型。
378 2
ERP系统源码,基于SpringBoot+Vue+ElementUI+UniAPP开发
|
8月前
|
JavaScript Java 测试技术
基于SpringBoot+Vue实现的留守儿童爱心网站设计与实现(计算机毕设项目实战+源码+文档)
博主是一位全网粉丝超过100万的CSDN特邀作者、博客专家,专注于Java、Python、PHP等技术领域。提供SpringBoot、Vue、HTML、Uniapp、PHP、Python、NodeJS、爬虫、数据可视化等技术服务,涵盖免费选题、功能设计、开题报告、论文辅导、答辩PPT等。系统采用SpringBoot后端框架和Vue前端框架,确保高效开发与良好用户体验。所有代码由博主亲自开发,并提供全程录音录屏讲解服务,保障学习效果。欢迎点赞、收藏、关注、评论,获取更多精品案例源码。
|
8月前
|
JavaScript Java 测试技术
基于SpringBoot+Vue实现的家政服务管理平台设计与实现(计算机毕设项目实战+源码+文档)
面向大学生毕业选题、开题、任务书、程序设计开发、论文辅导提供一站式服务。主要服务:程序设计开发、代码修改、成品部署、支持定制、论文辅导,助力毕设!
|
8月前
|
JavaScript 搜索推荐 Java
基于SpringBoot+Vue实现的家乡特色推荐系统设计与实现(源码+文档+部署)
面向大学生毕业选题、开题、任务书、程序设计开发、论文辅导提供一站式服务。主要服务:程序设计开发、代码修改、成品部署、支持定制、论文辅导,助力毕设!
|
8月前
|
JavaScript NoSQL Java
基于SpringBoot+Vue实现的大学生就业服务平台设计与实现(系统源码+文档+数据库+部署等)
面向大学生毕业选题、开题、任务书、程序设计开发、论文辅导提供一站式服务。主要服务:程序设计开发、代码修改、成品部署、支持定制、论文辅导,助力毕设!
|
8月前
|
JavaScript Java 测试技术
基于Java+SpringBoot+Vue实现的车辆充电桩系统设计与实现(系统源码+文档+部署讲解等)
面向大学生毕业选题、开题、任务书、程序设计开发、论文辅导提供一站式服务。主要服务:程序设计开发、代码修改、成品部署、支持定制、论文辅导,助力毕设!