PriorityBlockingQueue 是线程安全的无界优先队列，按自然顺序或自定义 Comparator 排序，出队返回最高优先级元素；不保证同优先级 FIFO，不支持 null，适用于任务调度等并发优先级场景。
PriorityBlockingQueue 是一个线程安全的无界优先队列，元素按自然顺序或自定义比较器排序，出队总是返回当前最小（或最大）优先级的元素。 它不保证相同优先级元素的处理顺序（即不保证 FIFO），也不支持 null 元素。适合需要并发环境下按优先级处理任务的场景，比如任务调度、消息分发等。
基本用法：创建与添加元素
默认按自然顺序排序（要求元素实现 Comparable 接口）：
- 直接 new PriorityBlockingQueue
()，插入 Integer 会按数值升序排列 - add()、put()、offer() 都可插入元素；由于是无界队列，add/put 永远不会阻塞或失败
- 注意：null 不允许插入，否则抛 NullPointerException
自定义排序规则
通过构造函数传入 Comparator 实现逆序或业务逻辑排序：
- 例如按字符串长度降序：
new PriorityBlockingQueue(11, (a, b) -> b.length() - a.length()) - Comparator 中不要抛异常，否则队列操作可能意外中断
- 如果元素本身不可比，又没传 Comparator，首次 poll 或 take 时会抛 ClassCastException
线程安全的取值操作
核心方法都是线程安全的，适用于多线程协作：
立即学习“Java免费学习笔记（深入）”；
-
take()：阻塞直到有元素可取，返回优先级最高的元素 -
poll()：立即返回最高优先级元素，若队列空则返回 null -
peek()：只查看不移除，同样返回最高优先级元素（可能为 null） - 所有取值操作都基于堆结构维护，时间复杂度为 O(log n)
注意事项与常见误区
它不是公平队列，相同优先级的元素顺序不确定：
- 不能依赖插入顺序处理同优先级任务；如需严格 FIFO，可将“插入时间戳”作为比较依据之一
- 无界特性意味着内存可能持续增长，生产环境建议配合监控或外部限流
- 不支持遍历强一致性：iterator() 返回的迭代器不保证反映实时排序结果，仅用于调试或快照
- size() 方法是 O(1)，但内部实际是基于堆，不支持随机访问或索引查找
基本上就这些。用好 PriorityBlockingQueue 的关键是理清“谁该先处理”的逻辑，并确保比较规则稳定、无歧义。
