PriorityQueue基于堆实现,默认小顶堆,入队出队O(log n),需注意非线程安全、不支持null、遍历无序,优先级由自然排序或Comparator决定,适合任务调度与Top K问题。

在Java中,PriorityQueue 是实现优先级队列最常用的方式。它基于堆(通常是二叉小顶堆)结构,能自动维护元素的优先级顺序,确保每次取出的都是当前优先级最高(默认最小)的元素。掌握其使用技巧,对处理任务调度、数据流排序等场景非常有帮助。
理解PriorityQueue的基本特性
PriorityQueue 不是线程安全的,不允许插入 null 值。它的出队顺序由元素的自然顺序或自定义比较器决定。入队(offer)和出队(poll)操作的时间复杂度为 O(log n),获取队首元素为 O(1)。
注意:PriorityQueue 并不保证遍历时的有序性,只有通过 poll() 才能按优先级顺序取出元素。
- 默认情况下,数值小的优先级高(小顶堆)
- 不能用于 null 元素的插入
- 不是同步的,多线程环境需自行同步或使用 PriorityBlockingQueue
使用自然排序与自定义比较器
对于实现了 Comparable 接口的类(如 Integer、String),可以直接使用自然排序:
立即学习“Java免费学习笔记(深入)”;
PriorityQueuepq.offer(5);
pq.offer(1);
pq.offer(3);
System.out.println(pq.poll()); // 输出 1
若要改变优先级规则,比如让大的数优先级更高,可以传入自定义 Comparator:
maxPQ.offer(5);
maxPQ.offer(1);
maxPQ.offer(3);
System.out.println(maxPQ.poll()); // 输出 5
处理自定义对象的优先级排序
当队列中存放的是自定义对象时,必须提供比较逻辑。例如,有一个任务类 Task,希望按优先级字段排序:
class Task {String name;
int priority;
Task(String name, int priority) {
this.name = name;
this.priority = priority;
}
}
PriorityQueue
taskQueue.offer(new Task("Low", 3));
taskQueue.offer(new Task("High", 1));
taskQueue.offer(new Task("Medium", 2));
System.out.println(taskQueue.poll().name); // 输出 High
这样就能确保优先级数字越小的任务越先执行。
常见使用技巧与注意事项
实际开发中有一些细节容易忽略,但会影响性能或逻辑正确性。
- 初始化时指定初始容量,避免频繁扩容:new PriorityQueue(16, comparator)
- 如果需要反向排序,推荐使用 Collections.reverseOrder() 而非手动写 (b,a)->b-a
- 修改队列中已存在元素的值不会触发堆结构调整,可能导致顺序错乱
- peek() 查看但不移除队首,适合“预览”最高优先级元素
- contains(element) 可判断是否存在某元素,但效率不高(O(n))
基本上就这些。PriorityQueue 使用简单但功能强大,关键是理解其排序机制和限制条件。合理使用比较器,注意对象可比性,就能在任务调度、Top K 问题、合并多个有序流等场景中发挥很好作用。










