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)保证并发下的堆结构调整原子性。你不需要手动加锁,直接调用即可。
不会阻塞(除非显式调用 put)
注意:
-
offer(E)立即返回,永远成功(容量无限),不会阻塞; -
put(E)也永远不会阻塞 —— 因为 PriorityBlockingQueue 是无界队列,内部数组会动态扩容; - 所谓“Blocking”在这里有点误导:它继承自 BlockingQueue 接口,但仅对出队操作(如
take())才真正阻塞;入队永远非阻塞。
元素必须可比较,否则运行时报错
入队对象必须实现 Comparable 接口(且自然顺序合理),或队列创建时明确传入 Comparator。否则在第一次比较时抛出 ClassCastException。例如,往空队列中 add 一个没实现 Comparable 的普通对象,会在堆调整过程中失败。
升级报告:增加动态新闻功能后台添加,删除,编辑,支持UBB代码,支持上传片及文件。 增加我要入团功能散客可以自由选择加入贵社最近要出发的团队。 增加线路置顶功能置顶后的线路永远显示在最前面。 增加同行报价功能管理员在后台添加同行用户,同行用户登录后可查看贵社线路对同行的报价。同行报价在添加线路中一并添加。(感谢网友拽哥提出修改意见) 增加更多线路显示的分页功能方便大型旅行社由于线路过多而引起的部分
立即学习“Java免费学习笔记(深入)”;
基本上就这些。入队逻辑清晰,关键是理解它背后是堆,不是链表或数组队列。










