diff --git a/common/src/main/java/org/dromara/dynamictp/common/queue/VariableLinkedBlockingQueue.java b/common/src/main/java/org/dromara/dynamictp/common/queue/VariableLinkedBlockingQueue.java
index 543da85c9..7a256f3e5 100644
--- a/common/src/main/java/org/dromara/dynamictp/common/queue/VariableLinkedBlockingQueue.java
+++ b/common/src/main/java/org/dromara/dynamictp/common/queue/VariableLinkedBlockingQueue.java
@@ -505,7 +505,7 @@ public E take() throws InterruptedException {
         } finally {
             takeLock.unlock();
         }
-        if (c >= capacity) {
+        if (c == capacity) {
             signalNotFull();
         }
         return x;
@@ -534,7 +534,7 @@ public E poll(long timeout, TimeUnit unit) throws InterruptedException {
         } finally {
             takeLock.unlock();
         }
-        if (c >= capacity) {
+        if (c == capacity) {
             signalNotFull();
         }
         return x;
@@ -561,7 +561,7 @@ public E poll() {
         } finally {
             takeLock.unlock();
         }
-        if (c >= capacity) {
+        if (c == capacity) {
             signalNotFull();
         }
         return x;