PriorityBlockingQueue是Java中支持优先级的无界线程安全队列，基于堆实现，元素需实现Comparable或提供Comparator，不允许null值，适用于多线程任务调度场景。
在Java中，PriorityBlockingQueue 是一个支持优先级排序的无界并发安全队列。它位于 java.util.concurrent 包下，适用于多线程环境下需要按优先级处理任务的场景。这个队列使用堆结构维护元素顺序，确保每次取出的都是当前优先级最高的元素。
1. PriorityBlockingQueue 的基本特性
PriorityBlockingQueue 具有以下几个关键特点：
- 线程安全：内部通过锁机制保证多线程操作的安全性。
- 无界队列：容量可自动扩容，不会阻塞入队操作（除非内存耗尽）。
- 基于优先级排序：元素必须实现
Comparable接口，或在构造时提供Comparator来定义排序规则。 - 不允许 null 值：插入 null 会抛出
NullPointerException。
2. 创建和初始化 PriorityBlockingQueue
可以通过默认构造函数创建，也可以指定初始容量和比较器。
// 使用默认初始容量（11），元素需实现 Comparable PriorityBlockingQueue<Integer> queue = new PriorityBlockingQueue<>(); <p>// 指定初始容量 PriorityBlockingQueue<Integer> queue2 = new PriorityBlockingQueue<>(20);</p><p>// 提供 Comparator 控制优先级顺序（例如：小数优先） PriorityBlockingQueue<Integer> queue3 = new PriorityBlockingQueue<>( 10, Comparator.naturalOrder() // 或 (a, b) -> a - b );</p>
3. 添加和移除元素
常用方法包括 put()、offer()、take() 和 poll()。
立即学习“Java免费学习笔记（深入）”；
PriorityBlockingQueue<Integer> queue = new PriorityBlockingQueue<>(); <p>queue.put(5); // 插入元素，不会阻塞 queue.offer(3); // 相同效果，推荐用于非阻塞场景 queue.add(7); // 也可用 add，但失败会抛异常</p><p>// 取出优先级最高的元素（最小值） Integer first = queue.take(); // 阻塞等待，直到有元素可用 Integer next = queue.poll(); // 非阻塞，队列空时返回 null</p>
4. 自定义对象的优先级排序
若要存储自定义对象，必须提供排序依据。
class Task implements Comparable<Task> {
String name;
int priority; // 数值越小，优先级越高
<pre class='brush:java;toolbar:false;'>public Task(String name, int priority) {
this.name = name;
this.priority = priority;
}
@Override
public int compareTo(Task other) {
return Integer.compare(this.priority, other.priority);
}
@Override
public String toString() {
return "Task{" + "name='" + name + '\'' + ", priority=" + priority + '}';
}}
// 使用示例 PriorityBlockingQueue<Task> taskQueue = new PriorityBlockingQueue<>(); taskQueue.put(new Task("Low", 3)); taskQueue.put(new Task("High", 1)); taskQueue.put(new Task("Medium", 2));
while (!taskQueue.isEmpty()) { System.out.println(taskQueue.take()); }
输出结果会按优先级升序打印任务。
5. 实际应用场景
常用于多线程环境下的任务调度系统，比如：
- 定时任务执行器：优先处理即将到期的任务。
- 事件驱动系统：紧急事件优先响应。
- 工作窃取框架中的本地队列（虽然通常用其他结构，但原理类似）。
基本上就这些。PriorityBlockingQueue 使用简单，关键是定义好排序逻辑，并注意它是无界的，防止内存溢出。不复杂但容易忽略的是：一定要确保比较逻辑正确，否则队列行为会不符合预期。
