Elgato_dark/sol-cloud
1
0
Fork 0
mirror of https://github.com/BgaSol/sol-cloud synced 2026-04-21 17:17:16 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor(threadpool): refactor ThreadPoolTaskExecutor

Browse source
This commit is contained in:
smile 2025-12-01 16:49:32 +08:00
parent 3f39223c7f
commit 6881da91d8
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
cloud/common/common-base-web/src/main/java/com/bgasol/common/core/base/config/ThreadPoolConfig.java
View file

@ -16,13 +16,13 @@ public class ThreadPoolConfig {
*/
@Bean("cpuThreadPool")
public ThreadPoolTaskExecutor cpuThreadPool() {
int cores = Runtime.getRuntime().availableProcessors() / 2;
int cores = Runtime.getRuntime().availableProcessors();
int corePoolSize = cores + 1;
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(corePoolSize);
executor.setQueueCapacity(500);
executor.setThreadNamePrefix("cpu-pool");
executor.setThreadNamePrefix("cpu-pool-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.setAllowCoreThreadTimeOut(true);
executor.initialize();
@ -35,14 +35,13 @@ public class ThreadPoolConfig {
*/
@Bean("ioThreadPool")
public ThreadPoolTaskExecutor ioThreadPool() {
int cores = Runtime.getRuntime().availableProcessors() / 2;
int cores = Runtime.getRuntime().availableProcessors();
int corePoolSize = cores * 2;
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(corePoolSize);
executor.setQueueCapacity(2000);
executor.setThreadNamePrefix("io-pool");
executor.setThreadNamePrefix("io-pool-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.setAllowCoreThreadTimeOut(true);
executor.initialize();