|
|
@@ -0,0 +1,32 @@
|
|
|
+package cn.iocoder.yudao.module.pms.config;
|
|
|
+
|
|
|
+import org.springframework.context.annotation.Bean;
|
|
|
+import org.springframework.context.annotation.Configuration;
|
|
|
+import org.springframework.scheduling.annotation.EnableAsync;
|
|
|
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
|
+
|
|
|
+import java.util.concurrent.ThreadPoolExecutor;
|
|
|
+
|
|
|
+@Configuration
|
|
|
+@EnableAsync(proxyTargetClass = true)
|
|
|
+public class ThreadPoolTaskConfig {
|
|
|
+ public static final int cpuNum = Runtime.getRuntime().availableProcessors();
|
|
|
+ private static final int corePoolSize = cpuNum;
|
|
|
+ private static final int maxPoolSize = cpuNum*2;
|
|
|
+ private static final int keepAliveTime = 30;
|
|
|
+ private static final int queueCapacity = 10000;
|
|
|
+ private static final String threadNamePrefix = "sip-";
|
|
|
+
|
|
|
+ @Bean("taskExecutor")
|
|
|
+ public ThreadPoolTaskExecutor taskExecutor() {
|
|
|
+ ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
|
|
|
+ executor.setCorePoolSize(corePoolSize);
|
|
|
+ executor.setMaxPoolSize(maxPoolSize);
|
|
|
+ executor.setQueueCapacity(queueCapacity);
|
|
|
+ executor.setKeepAliveSeconds(keepAliveTime);
|
|
|
+ executor.setThreadNamePrefix(threadNamePrefix);
|
|
|
+ executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
|
|
|
+ executor.initialize();
|
|
|
+ return executor;
|
|
|
+ }
|
|
|
+}
|
