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