基本接口和队列保持一样

int size(); // 元素的数量

boolean isEmpty(); // 是否为空

void enQueue(E element); // 入队

E deQueue(); // 出队

E front(); // 获取队列的头元素

void clear(); // 清空

实现比较简单

public class PriorityQueue<E> implements Queue<E> {

private final BinaryHeap<E> binaryHeap;

public PriorityQueue() {

binaryHeap = new BinaryHeap<>();

}

public PriorityQueue(Comparator<E> comparator) {

binaryHeap = new BinaryHeap<>(comparator);

}

@Override

public int size() {

return binaryHeap.size();

}

@Override

public boolean isEmpty() {

return size() == 0;

}

@Override

public void enQueue(E element) {

binaryHeap.add(element);

}

@Override

public E deQueue() {

return binaryHeap.remove();

}

@Override

public E front() {

return binaryHeap.get();

}

@Override

public void clear() {

binaryHeap.clear();

}

}

测试

public void test01() {

PriorityQueue<Person> priorityQueue = new PriorityQueue<>((p1, p2) -> p1.age - p2.age);

priorityQueue.enQueue(new Person(22, "张三"));

priorityQueue.enQueue(new Person(18, "李四"));

priorityQueue.enQueue(new Person(25, "王五"));

while (!priorityQueue.isEmpty()) {

System.out.println(priorityQueue.deQueue());

}

}

Person{age=25, name='王五'}

Person{age=22, name='张三'}

Person{age=18, name='李四'}

在`java.util`包下也有一个优先级队列`PriorityQueue`，API如下：


我们来看下如何给优先级队列添加元素


可以看到里面最重要的方法就是我们堆操作的`siftUp`，在点进去看就是和我们一样的堆操作的逻辑了，jdk的优先级队列底层就是`二叉堆`

可以看到批量建堆的源码跟我们一样采用的也是`自下而上的下滤`