package com.qianwen.smartman.modules.mdc.config;
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
@Configuration
|
public class TheadPoolTaskConfig {
|
@Bean({"threadPoolTaskExecutor"})
|
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
|
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
|
executor.setCorePoolSize(16);
|
executor.setQueueCapacity(1024);
|
executor.setMaxPoolSize(64);
|
executor.setKeepAliveSeconds(30);
|
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
|
executor.initialize();
|
return executor;
|
}
|
}
|
