ResizableCapacityLinkedBlockIngQueue 类名拼写修改为 ResizableCapacityLinkedB…

…lockingQueue，更加符合规范
opengoofy · Jun 7, 2022 · 9afe6ec · 9afe6ec
1 parent 62d7062
commit 9afe6ec
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 9 deletions.
diff --git a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/QueueTypeEnum.java b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/QueueTypeEnum.java
@@ -129,7 +129,7 @@ public static BlockingQueue createBlockingQueue(int type, Integer capacity) {
         } else if (Objects.equals(type, PRIORITY_BLOCKING_QUEUE.type)) {
             blockingQueue = new PriorityBlockingQueue(capacity);
         } else if (Objects.equals(type, RESIZABLE_LINKED_BLOCKING_QUEUE.type)) {
-            blockingQueue = new ResizableCapacityLinkedBlockIngQueue(capacity);
+            blockingQueue = new ResizableCapacityLinkedBlockingQueue(capacity);
         }
         Collection<CustomBlockingQueue> customBlockingQueues = DynamicThreadPoolServiceLoader
                 .getSingletonServiceInstances(CustomBlockingQueue.class);

diff --git a/...ResizableCapacityLinkedBlockIngQueue.java → ...ResizableCapacityLinkedBlockingQueue.java b/...ResizableCapacityLinkedBlockIngQueue.java → ...ResizableCapacityLinkedBlockingQueue.java
@@ -30,9 +30,9 @@
  * @date 2021/6/20 14:24
  */
 @Slf4j
-public class ResizableCapacityLinkedBlockIngQueue<E> extends LinkedBlockingQueue<E> {
+public class ResizableCapacityLinkedBlockingQueue<E> extends LinkedBlockingQueue<E> {
 
-    public ResizableCapacityLinkedBlockIngQueue(int capacity) {
+    public ResizableCapacityLinkedBlockingQueue(int capacity) {
         super(capacity);
     }
 

diff --git a/...r/src/main/java/cn/hippo4j/core/springboot/starter/refresher/event/ExecutorsListener.java b/...r/src/main/java/cn/hippo4j/core/springboot/starter/refresher/event/ExecutorsListener.java
@@ -24,7 +24,7 @@
 import cn.hippo4j.core.executor.support.AbstractDynamicExecutorSupport;
 import cn.hippo4j.core.executor.support.QueueTypeEnum;
 import cn.hippo4j.core.executor.support.RejectedTypeEnum;
-import cn.hippo4j.core.executor.support.ResizableCapacityLinkedBlockIngQueue;
+import cn.hippo4j.core.executor.support.ResizableCapacityLinkedBlockingQueue;
 import cn.hippo4j.core.proxy.RejectedProxyUtil;
 import cn.hippo4j.core.springboot.starter.config.BootstrapCoreProperties;
 import cn.hippo4j.core.springboot.starter.config.ExecutorProperties;
@@ -188,8 +188,8 @@ private void dynamicRefreshPool(String threadPoolId, ExecutorProperties properti
         }
         if (!Objects.equals(beforeProperties.getQueueCapacity(), properties.getQueueCapacity())
                 && Objects.equals(QueueTypeEnum.RESIZABLE_LINKED_BLOCKING_QUEUE.name, executor.getQueue().getClass().getSimpleName())) {
-            if (executor.getQueue() instanceof ResizableCapacityLinkedBlockIngQueue) {
-                ResizableCapacityLinkedBlockIngQueue<?> queue = (ResizableCapacityLinkedBlockIngQueue<?>) executor.getQueue();
+            if (executor.getQueue() instanceof ResizableCapacityLinkedBlockingQueue) {
+                ResizableCapacityLinkedBlockingQueue<?> queue = (ResizableCapacityLinkedBlockingQueue<?>) executor.getQueue();
                 queue.setCapacity(properties.getQueueCapacity());
             } else {
                 log.warn("The queue length cannot be modified. Queue type mismatch. Current queue type :: {}", executor.getQueue().getClass().getSimpleName());

diff --git a/...rter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java b/...rter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java
@@ -28,7 +28,7 @@
 import cn.hippo4j.core.executor.support.AbstractDynamicExecutorSupport;
 import cn.hippo4j.core.executor.support.QueueTypeEnum;
 import cn.hippo4j.core.executor.support.RejectedTypeEnum;
-import cn.hippo4j.core.executor.support.ResizableCapacityLinkedBlockIngQueue;
+import cn.hippo4j.core.executor.support.ResizableCapacityLinkedBlockingQueue;
 import cn.hippo4j.core.proxy.RejectedProxyUtil;
 import cn.hippo4j.common.api.ThreadPoolDynamicRefresh;
 import lombok.AllArgsConstructor;
@@ -148,8 +148,8 @@ public void changePoolInfo(ThreadPoolExecutor executor, ThreadPoolParameter para
         }
         if (parameter.getCapacity() != null
                 && Objects.equals(QueueTypeEnum.RESIZABLE_LINKED_BLOCKING_QUEUE.type, parameter.getQueueType())) {
-            if (executor.getQueue() instanceof ResizableCapacityLinkedBlockIngQueue) {
-                ResizableCapacityLinkedBlockIngQueue queue = (ResizableCapacityLinkedBlockIngQueue) executor.getQueue();
+            if (executor.getQueue() instanceof ResizableCapacityLinkedBlockingQueue) {
+                ResizableCapacityLinkedBlockingQueue queue = (ResizableCapacityLinkedBlockingQueue) executor.getQueue();
                 queue.setCapacity(parameter.getCapacity());
             } else {
                 log.warn("The queue length cannot be modified. Queue type mismatch. Current queue type :: {}", executor.getQueue().getClass().getSimpleName());