跳转到主内容
极星编程网:以代码为星,赴技术山海!

java中PriorityBlockingQueue的入队

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 的普通对象,会在堆调整过程中失败。 Eclipse导入Android或其他的JAVA项目的正确方法 WORD版 本文档主要讲述的是Eclipse导入Android或其他的JAVA项目的正确方法;希望本文档会给有需要的朋友带来帮助;感兴趣的朋友可以过来看看 下载 立即学习 “ Java免费学习笔记(深入) ”; 基本上就这些。入队逻辑清晰,关键是理解它背后是堆,不是链表或数组队列。

相关文章