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();