PriorityQueue 是实现任务优先级调度的最优选择,因其基于堆结构支持 O(log n) 插入与弹出,配合自定义 Comparator 可灵活定义优先级逻辑,并需搭配 ConcurrentHashMap 管理任务状态以保障并发安全。
用 PriorityQueue 实现任务优先级调度
任务管理器最核心的需求之一是按优先级执行,Java 原生集合中 PriorityQueue 是最直接的选择——它底层基于堆,插入和弹出最小(或最大)元素的时间复杂度都是 O(log n),无需手动排序。
注意:默认构造的 PriorityQueue 按自然顺序升序排列(即“数值越小,优先级越高”),若任务优先级数字越大越紧急,必须传入自定义 Comparator:
PriorityQueue queue = new PriorityQueue((t1, t2) -> Integer.compare(t2.getPriority(), t1.getPriority()));
- 别直接用
new PriorityQueue(Collections.reverseOrder()),它只对Comparable类型有效,而Task通常不实现Comparable -
PriorityQueue不保证遍历时有序,只能靠poll()或peek()获取顶部任务;遍历用stream().sorted()是错的——那会破坏队列语义且性能差 - 如果需要按时间+优先级双重排序(比如“今天到期的高优任务先执行”),
Comparator必须完整表达业务逻辑,不能只比一个字段
用 ConcurrentHashMap 存储任务状态并支持并发读写
单线程下用 HashMap 足够,但真实任务管理器常需多线程触发(如定时线程扫描、UI 线程更新状态、后台线程执行完成回调)。此时 ConcurrentHashMap 是安全又高效的选择。
关键点不是“线程安全”,而是“避免锁粒度太大”:ConcurrentHashMap 分段锁或 CAS 操作,比 Collections.synchronizedMap() 的全表锁快得多。
立即学习“Java免费学习笔记(深入)”;