PriorityBlockingQueue入队是插入并自动堆化排序,非简单追加;基于可变数组的最小堆,线程安全,offer/put均不阻塞,元素须可比较。
PriorityBlockingQueue 的入队操作本质是插入元素并维持堆序性
,不是简单追加到队尾。
PriorityBlockingQueue 底层基于可变数组的最小堆(默认),每次 put() 或 offer() 入队后,元素会根据其自然顺序(或构造时传入的 Comparator)调整位置,确保队首始终是优先级最高的元素。比如插入 5、2、8、1,实际内部存储顺序不会是 [5,2,8,1],而是通过上浮(sift-up)调整为符合最小堆结构的排列,队首始终为 1。
所有入队方法(put(E)、offer(E)、offer(E, long, TimeUnit))都是线程安全的。内部使用可重入锁(ReentrantLock)保证并发下的堆结构调整原子性。你不需要手动加锁,直接调用即可。
注意:
offer(E) 立即返回,永远成功(容量无限),不会阻塞;put(E) 也永远不会阻塞 —— 因为 PriorityBlockingQueue 是无界队列,内部数组会动态扩容;take())才真正阻塞;入队永远非阻塞。入队对象必须实现 Comparable 接口(且自然顺序合理),或队列创建时明确传入 Comparator。否则在第一次比较时抛出 ClassCastException。例如,往空队列中 add 一个没实现 Comparable 的普通对象,会在堆调整过程中失败。
基本上就这些。入队逻辑清晰,关键是理解它背后是堆,不是链表或数组队列。