SpringBoot 集成线程池

心已赠人 2023-10-18 16:47 225阅读 0赞

1、项目结构说明：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70][]

2、线程池核心代码：

package com.zzg.threadpool.config;
    
    import java.util.concurrent.Executor;
    import java.util.concurrent.ThreadPoolExecutor;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    /**
     * 
     * @ClassName:  ThreadPoolConfig   
     * @Description: 线程池配置类   
     * @author: **** -zzg
     * @date:   2019年4月9日 上午10:31:49   
     *     
     * @Copyright: 2019 www.digipower.cn 
     * 注意：本内容仅限于*****科技开发有限公司内部使用，禁止用于其他的商业目的
     */
    @Configuration
    public class ThreadPoolConfig {
    	/**
    	 * 
    	 * @Title: threadPoolTaskExecutor @Description: TODO
    	 * 节点创建默认工作线程池。 @param: @return @return: Executor @throws
    	 */
    	@Bean(name = "threadPoolTaskExecutor")
    	public Executor taskExecutor() {
    		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    		executor.setCorePoolSize(5);
    		executor.setMaxPoolSize(10);
    		executor.setQueueCapacity(200);
    		executor.setKeepAliveSeconds(60);
    		executor.setThreadNamePrefix("threadpool-");
    		executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    		return executor;
    	}
    
    }

3、线程池功能测试：

package com.zzg.cron.component;
    
    import org.springframework.scheduling.annotation.Async;
    import org.springframework.stereotype.Component;
    
    import com.zzg.cron.abstr.CronAbstract;
    
    @Component("cronThreadPoolObject")
    public class CronThreadPoolObject extends CronAbstract {
    
    	@Override
    	@Async(value = "threadPoolTaskExecutor")
    	public void execute() {
    		// TODO Auto-generated method stub
    		System.out.println("CronThreadPoolObject 对象执行输出任务:" + Thread.currentThread().getName());
    	}
    
    }

注： 直接使用@Async注解，并声明线程池，即可使用多线程；

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190409104809317.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n,size_16,color_FFFFFF,t_70