From abfa682ecfd4f5bb3407b8b6a5f9f4283b2b6960 Mon Sep 17 00:00:00 2001
From: xingyiteng <49838409+xingyiteng@users.noreply.github.com>
Date: Sat, 29 Jun 2024 17:11:38 +0800
Subject: [PATCH] Update VariableLinkedBlockingQueue.java
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

fix：VariableLinkedBlockingQueue的take、poll方法优化
---
 .../dynamictp/common/queue/VariableLinkedBlockingQueue.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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;