SpringBoot如何使用多线程执行任务

package com.cy;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
@SpringBootApplication
@EnableAsync //表示开启异步
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}
复制

@Configuration
public class SpringThreadPoolConfig {
  @Value("${async-thread-pool.corePoolSize}")
  private int corePoolSize=2;
  @Value("${async-thread-pool.maxPoolSize}")
  private int maxPoolSize=5;
  @Value("${async-thread-pool.keepAliveSeconds}")
  private int keepAliveSeconds=60*5;
  @Value("${async-thread-pool.queueCapacity}")
  private int queueCapacity=5;
  
  /**创建线程工厂对象：目的是创建线程时为线程起个名字*/
  private ThreadFactory threadFactory=new ThreadFactory() {
    private AtomicLong count=new AtomicLong(1);//CAS算法
    @Override
    public Thread newThread(Runnable r) {
      return new Thread(r,"db-service-thread-name-"+count.getAndIncrement());
    }
  };
  
  @Bean
  public Executor asyncExecutor() {
    System.out.println("corePoolSize="+corePoolSize);
    //构建阻塞式队列
    BlockingQueue<Runnable> workQueue=
    new LinkedBlockingDeque<>(queueCapacity);
    //构建线程池对象(tomcat中默认用的线程池也是这个类型)
    ThreadPoolExecutor executor=
        new ThreadPoolExecutor(corePoolSize,
            maxPoolSize, 
            keepAliveSeconds, 
            TimeUnit.SECONDS,
            workQueue,
            threadFactory,
            new ThreadPoolExecutor.CallerRunsPolicy());
    return executor;
  }
}
复制

#spring async pool
async-thread-pool:
  corePoolSize: 5
  maxPoolSize: 10
  keepAliveSeconds: 30
  queueCapacity: 30
复制

@Transactional(propagation = Propagation.REQUIRES_NEW)
            @Async("asyncExecutor")
            @Override
            public Future<PageObject<SysLog>> findPageObjects(
                            String name, Integer pageCurrent) {
                    //1.验证参数合法性
                    //1.1验证pageCurrent的合法性，
                    //不合法抛出IllegalArgumentException异常
                    if(pageCurrent==null||pageCurrent<1)
                    throw new IllegalArgumentException("当前页码不正确");
                    //2.基于条件查询总记录数
                    //2.1) 执行查询
                    
                    int rowCount=sysLogDao.getRowCount(name);
                    //2.2)验证查询结果，假如结果为0不再执行如下操作
                    if(rowCount==0)
                    throw new ServiceException("系统没有查到对应记录");
                    //3.基于条件查询当前页记录(pageSize定义为2)
                    //3.1)定义pageSize
                    int pageSize=2;
                    //3.2)计算startIndex
                    int startIndex=(pageCurrent-1)*pageSize;
                    //3.3)执行当前数据的查询操作
                    List<SysLog> records=
                    sysLogDao.findPageObjects(name, startIndex, pageSize);
                    //4.对分页信息以及当前页记录进行封装
                    //4.1)构建PageObject对象
                    PageObject<SysLog> pageObject=new PageObject<>();
                    //4.2)封装数据
                    pageObject.setPageCurrent(pageCurrent);
                    pageObject.setPageSize(pageSize);
                    pageObject.setRowCount(rowCount);
                    pageObject.setRecords(records);
             pageObject.setPageCount((rowCount-1)/pageSize+1);
                    //5.返回封装结果。
                    return new AsyncResult<PageObject<SysLog>>(pageObject);
            }
复制