7x31
/
databasir
mirror of https://github.com/vran-dev/databasir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feix: mail thread core should lt max

This commit is contained in:
vran 2022-04-12 10:13:37 +08:00
parent a3c0c70f46
commit 6c81603d75
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/src/main/java/com/databasir/core/config/AsyncConfig.java
View File

@ -8,6 +8,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
@EnableAsync @EnableAsync
@Configuration @Configuration
@ -16,11 +17,15 @@ public class AsyncConfig implements AsyncConfigurer {
@Bean @Bean
public Executor mailThreadPoolTaskExecutor() { public Executor mailThreadPoolTaskExecutor() {
final int maxCorePoolSize = 16;
final int maxPoolSize = 32;
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
int availableProcessorCount = Runtime.getRuntime().availableProcessors(); int availableProcessorCount = Runtime.getRuntime().availableProcessors();
executor.setCorePoolSize(availableProcessorCount << 1); int corePoolSize = Math.min(maxCorePoolSize, availableProcessorCount);
executor.setMaxPoolSize(32); executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(maxPoolSize);
executor.setAllowCoreThreadTimeOut(true); executor.setAllowCoreThreadTimeOut(true);
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
return executor; return executor;
} }
} }