From e944aa7f4d2c1dd7ce6efd97a6489f9617207d44 Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Fri, 20 Sep 2024 16:06:02 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DBoundedPriorityBlockingQueue#?= =?UTF-8?q?offer=E6=96=B9=E6=B3=95=E4=B8=80=E5=A4=84=E7=BB=86=E8=8A=82?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/yomahub/liteflow/util/BoundedPriorityBlockingQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/util/BoundedPriorityBlockingQueue.java b/liteflow-core/src/main/java/com/yomahub/liteflow/util/BoundedPriorityBlockingQueue.java index 62e89afc3..3ba1cda1b 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/util/BoundedPriorityBlockingQueue.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/util/BoundedPriorityBlockingQueue.java @@ -49,7 +49,7 @@ public class BoundedPriorityBlockingQueue extends PriorityBlockingQueue { if (size() >= capacity) { E head = peek(); if (this.comparator().compare(e, head) <= 0) { - return true; + return false; } // 当队列满时,就要淘汰顶端队列 poll();