springboot 多线程

小灰灰 2022-04-24 10:00 187阅读 0赞

1.写一个线程池配置类

import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    import java.util.concurrent.Executor;
    import java.util.concurrent.ThreadPoolExecutor;
    
    /**
     * @Author: renbaojia
     * @CreateDate: 2019-04-22 17:36:27
     * @Description: 线程池配置类
     * @Version: 3.4.0
     */
    @Configuration
    @EnableAsync
    public class ThreadPoolConfig {
        private static final Logger LOGGER = LoggerFactory.getLogger(ThreadPoolConfig.class);
    
    
        @Value("SPRING.")
        /**
         * 参数最好写载配置文件
         * @return Executor
         */
        @Bean
        public Executor asyncServiceExecutor() {
            LOGGER.info("start asyncServiceExecutor");
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            //配置核心线程数
            executor.setCorePoolSize(5);
            //配置最大线程数
            executor.setMaxPoolSize(5);
            //配置队列大小
            executor.setQueueCapacity(99999);
            //配置线程池中的线程的名称前缀
            executor.setThreadNamePrefix("async-timp-service-");
    
            // rejection-policy：当pool已经达到max size的时候，如何处理新任务
            // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
            executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
            //执行初始化
            executor.initialize();
            return executor;
        }
    }

2.使用在方法上加上@Async

//asyncServiceExecutor为方法名
    @Async("asyncServiceExecutor")

这个是最基本的线程池 比如我们想要看到线程池每次正在执行的队列 线程池大小 正在运行的线程的话 我们可以实现ThreadPoolTaskExecutor 的子类 获取里面的

getCorePoolSize

getMaxPoolSize

实现