PriorityQueue是Java中基于堆实现的优先队列,默认为最小堆,支持自定义Comparator,不可存null,非线程安全,常用方法包括offer、poll、peek等,适用于动态维护最值场景。

在Java中,PriorityQueue 是一个基于堆结构实现的优先队列,能够自动根据元素的优先级进行排序。默认情况下,它实现的是最小堆,即队列头部是最小的元素。通过自定义比较器,也可以实现最大堆或其他排序规则。
PriorityQueue的基本特性
PriorityQueue 是 java.util 包下的类,实现了 Queue 接口。它的主要特点包括:
- 不保证线程安全(线程安全版本为 PriorityBlockingQueue)
- 不允许插入 null 元素
- 插入和删除操作的时间复杂度为 O(log n)
- 遍历顺序不保证有序(尽管出队是有序的)
常用操作方法解析
以下是 PriorityQueue 的核心方法及其使用说明:
1. 添加元素:offer(E e) / add(E e)
立即学习“Java免费学习笔记(深入)”;
将元素插入队列,自动调整堆结构以维持优先级顺序。两者功能相同,但 offer() 更推荐用于队列(符合 Queue 接口规范)。
示例:
PriorityQueuepq = new PriorityQueue<>(); pq.offer(5); pq.offer(1); pq.offer(3); // 队头现在是 1
2. 获取并移除队头:poll()
返回并移除优先级最高(默认最小)的元素。如果队列为空,返回 null。
示例:
Integer top = pq.poll(); // 返回 1
3. 获取但不移除队头:peek()
查看队列头部元素,不删除。队列为空时返回 null。
示例:
Integer head = pq.peek(); // 查看但不取出
4. 删除指定元素:remove(Object o)
删除队列中首次出现的指定元素,删除成功返回 true。时间复杂度为 O(n)。
5. 检查是否包含元素:contains(Object o)
判断队列是否包含某个元素,返回布尔值。
6. 获取大小和判断是否为空:size()、isEmpty()
常规操作,用于控制循环或判断状态。
自定义优先级:使用 Comparator
默认情况下,PriorityQueue 对实现了 Comparable 的类型按自然顺序排序。若需自定义排序,可通过构造函数传入 Comparator。
例如,实现最大堆:
PriorityQueuemaxPQ = new PriorityQueue<>((a, b) -> b - a); maxPQ.offer(5); maxPQ.offer(1); maxPQ.offer(3); maxPQ.peek(); // 返回 5
也可以用于自定义对象,比如任务按优先级排序:
class Task {
String name;
int priority;
Task(String name, int priority) {
this.name = name;
this.priority = priority;
}
}
PriorityQueue taskQueue = new PriorityQueue<>(
(t1, t2) -> t2.priority - t1.priority
);
注意事项与常见问题
使用 PriorityQueue 时需注意以下几点:
- 元素必须可比较:要么实现 Comparable 接口,要么提供 Comparator
- 不能存 null,否则抛出 NullPointerException
- 迭代器遍历顺序不一定是排序顺序
- 修改集合结构时(如并发修改),迭代器会抛出 ConcurrentModificationException
基本上就这些。PriorityQueue 在处理需要动态维护最小/最大值的场景非常高效,比如 Dijkstra 算法、合并 K 个有序链表、任务调度等。掌握其核心方法和排序机制,能大幅提升算法实现效率。










