Java优先级队列使用详解

// 使用默认初始容量（11），元素需实现 Comparable
PriorityBlockingQueue queue = new PriorityBlockingQueue<>();
// 指定初始容量
PriorityBlockingQueue queue2 = new PriorityBlockingQueue<>(20);
// 提供 Comparator 控制优先级顺序（例如：小数优先）
PriorityBlockingQueue queue3 = new PriorityBlockingQueue<>(
10, 
Comparator.naturalOrder() // 或 (a, b) -> a - b
);

PriorityBlockingQueue queue = new PriorityBlockingQueue<>();
queue.put(5);  // 插入元素，不会阻塞
queue.offer(3); // 相同效果，推荐用于非阻塞场景
queue.add(7);   // 也可用 add，但失败会抛异常
// 取出优先级最高的元素（最小值）
Integer first = queue.take(); // 阻塞等待，直到有元素可用
Integer next = queue.poll();  // 非阻塞，队列空时返回 null

class Task implements Comparable {
    String name;
    int priority; // 数值越小，优先级越高
public Task(String name, int priority) {
    this.name = name;
    this.priority = priority;
}

@Override
public int compareTo(Task other) {
    return Integer.compare(this.priority, other.priority);
}

@Override
public String toString() {
    return "Task{" + "name='" + name + '\'' + ", priority=" + priority + '}';
}
}
// 使用示例
PriorityBlockingQueue taskQueue = new PriorityBlockingQueue<>();
taskQueue.put(new Task("Low", 3));
taskQueue.put(new Task("High", 1));
taskQueue.put(new Task("Medium", 2));
while (!taskQueue.isEmpty()) {
System.out.println(taskQueue.take());
}