diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java index 55d4c368..1078b43e 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java @@ -67,7 +67,7 @@ public class ThreadPoolDynamicRefresh { } if (parameter.getCapacity() != null - && Objects.equals(QueueTypeEnum.RESIZABLE_LINKED_BLOCKING_QUEUE.type, parameter.getQueueType())) { + && Objects.equals(QueueTypeEnum.RESIZABLE_LINKED_BLOCKING_QUEUE.name, executor.getQueue().getClass().getSimpleName())) { if (executor.getQueue() instanceof ResizableCapacityLinkedBlockIngQueue) { ResizableCapacityLinkedBlockIngQueue queue = (ResizableCapacityLinkedBlockIngQueue) executor.getQueue(); queue.setCapacity(parameter.getCapacity()); diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/toolkit/thread/QueueTypeEnum.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/toolkit/thread/QueueTypeEnum.java index 57717d48..9acb32b8 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/toolkit/thread/QueueTypeEnum.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/toolkit/thread/QueueTypeEnum.java @@ -20,37 +20,37 @@ public enum QueueTypeEnum { /** * {@link java.util.concurrent.ArrayBlockingQueue} */ - ARRAY_BLOCKING_QUEUE(1, "ArrayBlockingQueue"), + ARRAY_BLOCKING_QUEUE(1, ArrayBlockingQueue.class.getSimpleName()), /** * {@link java.util.concurrent.LinkedBlockingQueue} */ - LINKED_BLOCKING_QUEUE(2, "LinkedBlockingQueue"), + LINKED_BLOCKING_QUEUE(2, LinkedBlockingQueue.class.getSimpleName()), /** * {@link java.util.concurrent.LinkedBlockingDeque} */ - LINKED_BLOCKING_DEQUE(3, "LinkedBlockingDeque"), + LINKED_BLOCKING_DEQUE(3, LinkedBlockingDeque.class.getSimpleName()), /** * {@link java.util.concurrent.SynchronousQueue} */ - SYNCHRONOUS_QUEUE(4, "SynchronousQueue"), + SYNCHRONOUS_QUEUE(4, SynchronousQueue.class.getSimpleName()), /** * {@link java.util.concurrent.LinkedTransferQueue} */ - LINKED_TRANSFER_QUEUE(5, "LinkedTransferQueue"), + LINKED_TRANSFER_QUEUE(5, LinkedTransferQueue.class.getSimpleName()), /** * {@link java.util.concurrent.PriorityBlockingQueue} */ - PRIORITY_BLOCKING_QUEUE(6, "PriorityBlockingQueue"), + PRIORITY_BLOCKING_QUEUE(6, PriorityBlockingQueue.class.getSimpleName()), /** * {@link "io.dynamic.threadpool.starter.toolkit.thread.ResizableCapacityLinkedBlockIngQueue"} */ - RESIZABLE_LINKED_BLOCKING_QUEUE(9, "ResizableCapacityLinkedBlockIngQueue"); + RESIZABLE_LINKED_BLOCKING_QUEUE(9, ResizableCapacityLinkedBlockIngQueue.class.getSimpleName()); public Integer type;