修改线程数量
This commit is contained in:
@@ -17,17 +17,17 @@ import java.util.concurrent.TimeUnit;
|
|||||||
@Configuration
|
@Configuration
|
||||||
public class ExecutorConfig {
|
public class ExecutorConfig {
|
||||||
|
|
||||||
@Value("${task.pool.corePoolSize}")
|
// @Value("${task.pool.corePoolSize}")
|
||||||
private int corePoolSize;
|
private int corePoolSize=3;
|
||||||
|
|
||||||
// @Value("${task.pool.maxPoolSize}")
|
// @Value("${task.pool.maxPoolSize}")
|
||||||
private int maxPoolSize=12;
|
private int maxPoolSize=5;
|
||||||
|
|
||||||
// @Value("${task.pool.keepAliveSeconds}")
|
// @Value("${task.pool.keepAliveSeconds}")
|
||||||
private int keepAliveSeconds=6000000;
|
private int keepAliveSeconds=6000000;
|
||||||
|
|
||||||
// @Value("${task.pool.queueCapacity}")
|
// @Value("${task.pool.queueCapacity}")
|
||||||
private int queueCapacity=20;
|
private int queueCapacity=10;
|
||||||
|
|
||||||
private ThreadPoolTaskExecutor executor;
|
private ThreadPoolTaskExecutor executor;
|
||||||
private ThreadPoolExecutor blockingExecutor;
|
private ThreadPoolExecutor blockingExecutor;
|
||||||
|
|||||||
Reference in New Issue
Block a user