线程池config
@Configuration
public class ThreadPoolConfig {
@Resource
private ThreadPoolPropertiesthreadPoolProperties;
@Bean("testThreadPool")
public ThreadPoolTaskExecutortestThreadPool(){
ThreadPoolTaskExecutor threadPoolTaskExecutor =new ThreadPoolTaskExecutor();
//最大线程数
threadPoolTaskExecutor.setMaxPoolSize(threadPoolProperties.getMaxPoolSize());
//核心线程数
threadPoolTaskExecutor.setCorePoolSize(threadPoolProperties.getCorePoolSize());
//队列大小
threadPoolTaskExecutor.setQueueCapacity(threadPoolProperties.getQueueSize());
//线程最大空闲数
threadPoolTaskExecutor.setKeepAliveSeconds(threadPoolProperties.getKeepAliveSeconds());
//线程名前缀
threadPoolTaskExecutor.setThreadNamePrefix(threadPoolProperties.getThreadNamePrefix());
/**
* 自定义消费队列线程池
* CallerRunsPolicy 这个策略重试添加当前的任务，他会自动重复调用 execute() 方法，直到成功。
* AbortPolicy 对拒绝任务抛弃处理，并且抛出异常。
* DiscardPolicy 对拒绝任务直接无声抛弃，没有异常信息。
* DiscardOldestPolicy 对拒绝任务不抛弃，而是抛弃队列里面等待最久的一个线程，然后把拒绝任务加到队列。
*/
threadPoolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
return threadPoolTaskExecutor;
}
}
线程池参数config
@Configuration
@Data
@ConfigurationProperties(prefix ="async")
public class ThreadPoolProperties {
@ApiModelProperty("核心线程数")
private IntegercorePoolSize;
@ApiModelProperty("最大线程数")
private IntegermaxPoolSize;
@ApiModelProperty("队列大小")
private IntegerqueueSize;
@ApiModelProperty("线程最大空闲数")
private IntegerkeepAliveSeconds;
@ApiModelProperty("线程名前缀")
private StringthreadNamePrefix;
}
线程池参数可配置到配置文件中。
