diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ServerThreadPoolDynamicRefresh.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ServerThreadPoolDynamicRefresh.java index c756bd42d2ede589c2e75f7ee50601f5fa0ca59e..74bad8878f5da77181ea66edf8f388990eca1a7e 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ServerThreadPoolDynamicRefresh.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ServerThreadPoolDynamicRefresh.java @@ -123,14 +123,14 @@ public class ServerThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh * @param parameter */ public void changePoolInfo(ThreadPoolExecutor executor, PoolParameter parameter) { - if (parameter.getCoreSize() != null) { - executor.setCorePoolSize(parameter.getCoreSize()); - } - if (parameter.getMaxSize() != null) { executor.setMaximumPoolSize(parameter.getMaxSize()); } + if (parameter.getCoreSize() != null) { + executor.setCorePoolSize(parameter.getCoreSize()); + } + if (parameter.getCapacity() != null && Objects.equals(QueueTypeEnum.RESIZABLE_LINKED_BLOCKING_QUEUE.type, parameter.getQueueType())) { if (executor.getQueue() instanceof ResizableCapacityLinkedBlockIngQueue) {