17370845950

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

线程安全的取值操作

核心方法都是线程安全的，适用于多线程协作：

• take()：阻塞直到有元素可取，返回优先级最高的元素
• poll()：立即返回最高优先级元素，若队列空则返回 null
• peek()：只查看不移除，同样返回最高优先级元素（可能为 null）
• 所有取值操作都基于堆结构维护，时间复杂度为 O(log n)

注意事项与常见误区

它不是公平队列，相同优先级的元素顺序不确定：

• 不能依赖插入顺序处理同优先级任务；如需严格 FIFO，可将“插入时间戳”作为比较依据之一
• 无界特性意味着内存可能持续增长，生产环境建议配合监控或外部限流
• 不支持遍历强一致性：iterator() 返回的迭代器不保证反映实时排序结果，仅用于调试或快照
• size() 方法是 O(1)，但内部实际是基于堆，不支持随机访问或索引查找

基本上就这些。用好 PriorityBlockingQueue 的关键是理清“谁该先处理”的逻辑，并确保比较规则稳定、无歧义。