diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DynamicThreadPoolPostProcessor.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DynamicThreadPoolPostProcessor.java index 8c81b7a1..0072090f 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DynamicThreadPoolPostProcessor.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DynamicThreadPoolPostProcessor.java @@ -175,12 +175,11 @@ public final class DynamicThreadPoolPostProcessor implements BeanPostProcessor { } private final ExecutorService configRefreshExecutorService = ThreadPoolBuilder.builder() - .corePoolSize(2) - .maxPoolNum(4) + .corePoolSize(1) + .maxPoolNum(2) .keepAliveTime(2000) .timeUnit(TimeUnit.MILLISECONDS) - .workQueue(QueueTypeEnum.ARRAY_BLOCKING_QUEUE) - .capacity(1024) + .workQueue(QueueTypeEnum.SYNCHRONOUS_QUEUE) .allowCoreThreadTimeOut(true) .threadFactory("client.dynamic.threadPool.change.config") .rejected(new ThreadPoolExecutor.AbortPolicy())