使用PriorityQueue结合Comparable或Comparator实现任务优先级排序,优先级数值越小越先执行,通过poll()按序取出任务,确保高优先级任务优先处理。

在Java中实现任务优先级排序,最常用的方式是使用 PriorityQueue 结合自定义的比较器或让任务类实现 Comparable 接口。这样可以确保高优先级的任务先被处理。
1. 定义任务类并实现优先级逻辑
首先创建一个表示任务的类,比如 Task,包含任务名称和优先级字段。可以通过实现 Comparable 接口来定义默认排序规则,通常优先级数值越小,优先级越高(类似操作系统中的调度)。
public class Task implements Comparable{ private String name; private int priority; // 数值越小,优先级越高 public Task(String name, int priority) { this.name = name; this.priority = priority; } public String getName() { return name; } public int getPriority() { return priority; } @Override public int compareTo(Task other) { return Integer.compare(this.priority, other.priority); } @Override public String toString() { return "Task{name='" + name + "', priority=" + priority + '}'; } }
2. 使用 PriorityQueue 存储和调度任务
PriorityQueue 是基于堆的数据结构,能高效维护元素顺序。插入和取出操作的时间复杂度为 O(log n),适合频繁添加和提取任务的场景。
import java.util.PriorityQueue;
public class PriorityTaskScheduler {
public static void main(String[] args) {
PriorityQueue taskQueue = new PriorityQueue<>();
// 添加任务(优先级数字越小越优先)
taskQueue.offer(new Task("发送邮件", 3));
taskQueue.offer(new Task("保存日志", 2));
taskQueue.offer(new Task("系统初始化", 1));
taskQueue.offer(new Task("用户通知", 4));
// 按优先级执行任务
while (!taskQueue.isEmpty()) {
Task task = taskQueue.poll();
System.out.println("执行: " + task);
}
}
}
输出结果会是:
立即学习“Java免费学习笔记(深入)”;
执行: Task{name='系统初始化', priority=1}
执行: Task{name='保存日志', priority=2}
执行: Task{name='发送邮件', priority=3}
执行: Task{name='用户通知', priority=4}
3. 使用自定义 Comparator 实现灵活排序
如果不希望任务类本身实现 Comparable,或者需要多种排序方式,可以通过 Comparator 来定义优先级规则。
PriorityQueuetaskQueue = new PriorityQueue<>((t1, t2) -> Integer.compare(t1.getPriority(), t2.getPriority()) );
这种写法更灵活,比如可以轻松改为优先级数值越大越优先:
// 高数值优先 PriorityQueuehighPriorityFirst = new PriorityQueue<>((t1, t2) -> Integer.compare(t2.getPriority(), t1.getPriority()) );
4. 注意事项与建议
- PriorityQueue 不保证遍历时有序,只有调用 poll() 时才会按序取出。
- 不能直接修改队列中任务的优先级,否则会破坏堆结构。如需更新,应先移除再重新插入。
- 如果多个任务优先级相同,它们之间的顺序不确定(不保证 FIFO)。
- 若需稳定顺序(相同优先级按提交顺序处理),可引入时间戳字段,在比较时作为第二排序条件。










