Răsfoiți Sursa

修复BoundedPriorityBlockingQueue#offer方法一处细节问题

everywhere.z 8 luni în urmă
părinte
comite
e944aa7f4d

+ 1 - 1
liteflow-core/src/main/java/com/yomahub/liteflow/util/BoundedPriorityBlockingQueue.java

@@ -49,7 +49,7 @@ public class BoundedPriorityBlockingQueue<E> extends PriorityBlockingQueue<E> {
 		if (size() >= capacity) {
 			E head = peek();
 			if (this.comparator().compare(e, head) <= 0) {
-				return true;
+				return false;
 			}
 			// 当队列满时,就要淘汰顶端队列
 			poll();