【业务功能篇 143】Spring容器中的ThreadPoolTaskExecutor多线程，LinkedBlockingQueue问题

ゞ浴缸里的玫瑰 2024-05-02 20:09 42阅读 0赞

package com.config;
     
    import lombok.extern.slf4j.Slf4j;
     
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.scheduling.annotation.AsyncConfigurer;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
     
    import java.util.concurrent.ThreadPoolExecutor;
     
    /**
     * 线程池配置
     *
     */
    @Slf4j
    @Configuration
    @EnableAsync
    public class ThreadConfigurer implements AsyncConfigurer {
     
     
        /**
         * taskExecutor
         * 
         * @return ThreadPoolTaskExecutor
         */
        @Primary
        @Bean
        public ThreadPoolTaskExecutor taskExecutor() {
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
     
            //获取电脑的处理器数量，一般电脑一个处理器有两个逻辑线程
            int num = Runtime.getRuntime().availableProcessors();
            // 核心线程数目 核心线程数最好设置为电脑的逻辑线程总数 + 1，达到最大化利用处理器
            executor.setCorePoolSize(num * 2 + 1);
            // 指定最大线程数
            executor.setMaxPoolSize(200);
            // 队列中最大的数目
            executor.setQueueCapacity(100);
            // 线程名称前缀
            executor.setThreadNamePrefix("taskExecutor-");
            // 拒绝策略：不在新线程中执行任务，而是由调用者所在的线程来执行
            executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
            // 当调度器shutdown被调用时等待当前被调度的任务完成
            executor.setWaitForTasksToCompleteOnShutdown(true);
            // 线程空闲后的最大存活时间
            executor.setKeepAliveSeconds(60);
            // 线程池初始化
            executor.initialize();
            return executor;
        }
    }

[【业务功能篇42】ThreadPoolTaskExecutor多线程处理耗时较高的数据接口-CSDN博客][42_ThreadPoolTaskExecutor_-CSDN]

[Spring容器中的ThreadPoolTaskExecutor是否需要手动关闭\_threadpoolexecutor需要手动关闭吗-CSDN博客][Spring_ThreadPoolTaskExecutor_threadpoolexecutor_-CSDN]

[多线程系列：二、线程池在 Spring 中的使用与关闭\_springbatch split 线程池-CSDN博客][Spring _springbatch split _-CSDN]

[多线程系列：附、LinkedBlockingQueue 引发的一次线上事故\_linkedblockingqueue thread乱了-CSDN博客][LinkedBlockingQueue _linkedblockingqueue thread_-CSDN]

[42_ThreadPoolTaskExecutor_-CSDN]: https://blog.csdn.net/studyday1/article/details/131600824?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522171040582416800215036193%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=171040582416800215036193&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-1-131600824-null-null.nonecase&utm_term=%E5%A4%9A%E7%BA%BF%E7%A8%8B&spm=1018.2226.3001.4450
[Spring_ThreadPoolTaskExecutor_threadpoolexecutor_-CSDN]: https://blog.csdn.net/xhaimail/article/details/131976373
[Spring _springbatch split _-CSDN]: https://blog.csdn.net/BigBug_500/article/details/109961619
[LinkedBlockingQueue _linkedblockingqueue thread_-CSDN]: https://blog.csdn.net/BigBug_500/article/details/115051213