|
|
|
@ -33,8 +33,8 @@ public class ThreadPoolConfig {
|
|
|
|
@ConditionalOnProperty(prefix = "thread-pool", name = "enabled", havingValue = "true")
|
|
|
|
@ConditionalOnProperty(prefix = "thread-pool", name = "enabled", havingValue = "true")
|
|
|
|
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
|
|
|
|
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
|
|
|
|
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
|
|
|
|
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
|
|
|
|
executor.setMaxPoolSize(core);
|
|
|
|
executor.setCorePoolSize(core);
|
|
|
|
executor.setCorePoolSize(core * 2);
|
|
|
|
executor.setMaxPoolSize(core * 2);
|
|
|
|
executor.setQueueCapacity(threadPoolProperties.getQueueCapacity());
|
|
|
|
executor.setQueueCapacity(threadPoolProperties.getQueueCapacity());
|
|
|
|
executor.setKeepAliveSeconds(threadPoolProperties.getKeepAliveSeconds());
|
|
|
|
executor.setKeepAliveSeconds(threadPoolProperties.getKeepAliveSeconds());
|
|
|
|
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
|
|
|
|
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
|
|
|
|
|