priorityblockingqueue 是线程安全的无界优先队列，基于最小堆实现，支持自然排序或自定义 comparator，适用于多线程优先级任务调度，但不支持运行时修改优先级，需用“标记失效+重新入队”等策略应对动态变化。
PriorityBlockingQueue 是 Java 并发包中一个线程安全的无界优先队列，适合在多线程环境下实现任务按优先级调度执行。它内部基于堆结构（默认最小堆），支持自然排序或自定义 Comparator，且所有操作（如 put、take）都是线程安全的，无需额外加锁。
定义可比较的任务类
要让任务按优先级入队，需确保任务对象可比较。常见做法是让任务类实现 Comparable 接口，或在构造 PriorityBlockingQueue 时传入 Comparator。
- 实现 Comparable：重写 compareTo()，例如按 priority 字段升序（数值越小优先级越高）
- 使用 Comparator 更灵活：可在创建队列时指定，比如按 deadline 时间早的优先、或按业务权重倒序
- 注意：任务对象字段应为 final 或不可变，避免在队列中被修改导致堆结构错乱
构建线程安全的任务分发器
用 PriorityBlockingQueue 搭配 ExecutorService 可构建优先级感知的任务执行器。典型结构是：生产者线程调用 put() 提交任务，消费者线程调用 take() 获取最高优先级任务执行。
- 避免用 poll() 非阻塞取任务，否则可能空转浪费 CPU；take() 会阻塞直到有任务可用
- 若需支持取消或超时，可用 poll(long, TimeUnit)，但要注意返回 null 时需做空值判断
- 多个消费者线程共用同一个队列即可，PriorityBlockingQueue 内部已用 ReentrantLock + Condition 保证并发安全
处理优先级动态变化的场景
PriorityBlockingQueue 不支持运行时调整已有元素优先级——一旦入队，其位置由插入时的比较结果决定，后续修改字段不会触发重排序。
- 若任务优先级可能变化（如用户提升紧急度），推荐“标记失效 + 重新入队”策略：给任务加 version 或 status 字段，消费时校验有效性；无效则跳过，有效才执行
- 也可用 ScheduledThreadPoolExecutor 配合延迟提交，把高优任务设为更短 delay，间接实现动态调度
- 真正需要运行时重排序的场景，可考虑用 ConcurrentSkipListMap 替代，以 priority+timestamp 为 key，但需自行管理线程安全和阻塞逻辑
实际使用中的关键细节
PriorityBlockingQueue 虽方便，但有几个易忽略点直接影响稳定性：
- 它不保证相同优先级元素的 FIFO 顺序，若需稳定排序，Comparator 中必须加入唯一标识（如提交时间戳或序列号）作为第二排序条件
- 队列无界，大量低优先级任务堆积可能导致内存溢出，建议结合 reject 策略或外部限流（如 Semaphore 控制提交速率）
- 迭代器（iterator()）返回的不是实时排序快照，而是弱一致性视图，不适合用于监控或调试排序逻辑
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
