PriorityBlockingQueue是线程安全的无界阻塞队列，基于优先级排序，适用于多线程任务调度；插入不阻塞，取元素可阻塞，元素需实现Comparable或提供Comparator，且不允许null值。
在Java中，PriorityBlockingQueue 是一个线程安全的无界阻塞队列，它根据元素的自然顺序或自定义比较器来维护元素的优先级。这意味着高优先级的任务会先被取出执行，非常适合用于多线程环境下的任务调度场景。
PriorityBlockingQueue 特点
理解其核心特性是正确使用的前提：
• 线程安全：内部使用ReentrantLock保证并发访问的安全性。• 无界队列：容量可自动扩容，不会因为满而阻塞插入（除非内存耗尽）。
• 支持优先级排序：元素必须实现 Comparable 接口，或通过构造函数传入 Comparator。
• 插入不阻塞，取元素可阻塞：put() 和 add() 不会阻塞；take() 在队列为空时会阻塞直到有元素可用。
基本使用方法
下面是一个简单的示例，展示如何创建并操作 PriorityBlockingQueue：
假设我们要处理任务，优先级高的任务先执行：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.PriorityBlockingQueue;class Task implements Comparable
private int priority;
private String name;
public Task(int priority, String name) {
this.priority = priority;
this.name = name;
}
@Override
public int compareTo(Task other) {
return Integer.compare(this.priority, other.priority); // 小数字表示高优先级
}
@Override
public String toString() {
return "Task{" + "priority=" + priority + ", name='" + name + '\'' + '}';
}
}
使用队列进行任务调度：
// 添加任务
queue.put(new Task(3, "普通任务"));
queue.put(new Task(1, "紧急任务"));
queue.put(new Task(2, "重要任务"));
// 取出任务（按优先级）
System.out.println(queue.take()); // 输出：Task{priority=1, name='紧急任务'}
System.out.println(queue.take()); // 输出：Task{priority=2, name='重要任务'}
System.out.println(queue.take()); // 输出：Task{priority=3, name='普通任务'}
自定义比较器的使用
如果不希望类实现 Comparable，可以通过 Comparator 来定义优先级规则：
PriorityBlockingQueueInteger.compare(t2.priority, t1.priority)); // 逆序，高优先级数字大
上面代码中初始容量为11（只是初始值，实际无界），并使用 Lambda 表达式反转优先级顺序，使数值大的任务优先级更高。
常见操作与注意事项
常用方法包括：
• put(E e) / add(E e)：插入元素，不会阻塞。• take()：获取并移除头元素，队列为空时阻塞。
• poll(long timeout, TimeUnit unit)：带超时的取出操作。
• peek()：查看但不移除头元素，可能返回 null。
• size()：当前元素数量（注意在并发环境下可能变化）。
注意事项：
• 元素不能为 null，否则抛出 NullPointerException。• 虽然是“阻塞”队列，但只有取操作会阻塞，插入永远不会阻塞。
• 迭代器不保证按优先级顺序遍历，仅用于调试或监控用途。
• 如果多个元素优先级相同，顺序不保证（取决于堆结构和插入时机）。
基本上就这些。PriorityBlockingQueue 在需要线程安全且按优先级处理任务的场景下非常实用，比如后台任务调度系统、事件处理器等。只要元素能明确排序，用起来就很直观。
