Java中PriorityQueue通过自定义Comparator实现动态权重排序，支持Lambda、方法引用等方式；需注意其非线程安全、遍历无序、修改已入队元素权重不触发重排序等特性。
在 Java 中，PriorityQueue 默认按自然顺序排序（即元素需实现 Comparable），但实际开发中任务调度往往需要按动态权重（如优先级、截止时间、资源消耗等）排序。此时配合自定义 Comparator 是最常用且灵活的方式。
定义可比较的任务类
任务对象本身不需要实现 Comparable，只需包含权重字段（如 priority、deadline、cost 等），并提供对应 getter 方法：
public class Task {
private String name;
private int priority; // 数值越小优先级越高（默认逻辑）
private long deadline; // 时间戳，越早越紧急
public Task(String name, int priority, long deadline) {
this.name = name;
this.priority = priority;
this.deadline = deadline;
}
// getter 方法（必须有，Comparator 会用到）
public int getPriority() { return priority; }
public long getDeadline() { return deadline; }
public String getName() { return name; }
}
创建带 Comparator 的 PriorityQueue
直接在构造时传入 Comparator，支持 Lambda 表达式、方法引用或匿名内部类。常见场景如下：
-
按优先级升序（高优先出）：
(a, b) -> Integer.compare(a.getPriority(), b.getPriority()) -
按截止时间升序（紧急先出）：
Comparator.comparingLong(Task::getDeadline) -
复合权重：优先级为主，截止时间为辅：
(a, b) -> {<br> int cmp = Integer.compare(a.getPriority(), b.getPriority());<br> return cmp != 0 ? cmp : Long.compare(a.getDeadline(), b.getDeadline());<br> }
完整初始化示例：
立即学习“Java免费学习笔记（深入）”；
// 按 priority 升序 + deadline 升序（双关键排序）
PriorityQueue<Task> taskQueue = new PriorityQueue<>((a, b) -> {
int p = Integer.compare(a.getPriority(), b.getPriority());
if (p != 0) return p;
return Long.compare(a.getDeadline(), b.getDeadline());
});
插入与取出任务的注意事项
PriorityQueue 不是线程安全的，多线程环境需额外同步；另外它不保证遍历顺序，只保证 poll()、peek() 返回当前最高优先级元素：
- 用
offer(task)插入任务，自动按 Comparator 重新堆化 - 用
poll()取出并移除最高优先级任务（堆顶） - 用
peek()查看但不移除堆顶任务 - 修改已入队任务的权重字段 不会触发重排序 —— 必须先
remove()再offer()更新
进阶技巧：运行时切换排序逻辑
如果业务需要动态切换策略（比如从“紧急优先”切到“低耗优先”），可封装一个可变 Comparator：
public class DynamicTaskComparator implements Comparator<Task> {
private SortStrategy strategy = SortStrategy.BY_PRIORITY;
public void setStrategy(SortStrategy s) { this.strategy = s; }
@Override
public int compare(Task a, Task b) {
return switch (strategy) {
case BY_PRIORITY -> Integer.compare(a.getPriority(), b.getPriority());
case BY_DEADLINE -> Long.compare(a.getDeadline(), b.getDeadline());
case BY_COST -> Integer.compare(a.getCost(), b.getCost()); // 假设有 cost 字段
};
}
}
// 使用时：
DynamicTaskComparator comp = new DynamicTaskComparator();
PriorityQueue<Task> queue = new PriorityQueue<>(comp);
comp.setStrategy(SortStrategy.BY_DEADLINE); // 切换策略后，新插入元素生效
// 注意：已有元素不会自动重排，需重建队列或手动处理
不复杂但容易忽略：Comparator 一旦传入 PriorityQueue 就固定绑定，修改其内部状态仅影响后续插入和比较行为，已存在的元素位置不会自动调整。
