java.util.concurrent.PriorityBlockingQueue#siftUpComparable 代码很简单，记录一下。 /*** Inserts item x at position k, maintaining heap invariant by* promoting x up the tree until it is greater than or eq

PriorityBlockingQueue是一个支持优先级的无界阻塞队列，直到系统资源耗尽。默认情况下元素采用自然顺序升序排列。也可以自定义类实现compareTo()方法来指定元素排序规则，或者初始化PriorityBlockingQueue时，指定构造参数Comparator来对元素进行排序。但需要注意的是不能保证同优先级元素的顺序。PriorityBlockingQueue也是基于最小二叉

PriorityBLockingQueue-文档部分 doc文档 PriorityBlockingQueue是无界的阻塞队列。当然如果资源耗尽的看情况下也是会出现添加失败的情况。PriorityBlockingQueue提供的迭代器并不保证按照某一顺序顺序迭代所有元素（和有限队列一致，可以见另一篇博客源码分析-PriorityQueue）（它会先按数组迭代，然后再迭代漏掉的元素）。当两个元素相

PriorityBlockingQueue 的 常用场景及使用示例 PriorityBlockingQueue 是 Java 并发包 (java.util.concurrent) 中的一个线程安全的数据结构，它实现了 BlockingQueue 接口，并具备优先级排序功能。这个队列的特点是无界（除非系统资源耗尽）、线程安全，并且在插入或移除元素时可能会阻塞。 常用场景 任务调度：在多任务处

这就是带优先级的无界阻塞队列，每次出队都返回优先级最高或者最低的元素(这里规则可以自己制定)，内部是使用平衡二叉树实现的，遍历不保证有序； 其实也比较容易，就是基于数组实现的一个平衡二叉树，不了解平衡二叉树的可以先了解一下，别想的太难，原理跟链表差不多，只不过链表中指向下一个节点的只有一个，而平衡二叉树中有两个，一个左，一个右，还有左边的节点的值小于当前节点的值，右边节点的值大于当前节点的值；看

文章目录 简介PriorityQueuePriorityBlockingQueue PriorityQueue和PriorityBlockingQueue 简介 Queue一般来说都是FIFO的，当然之前我们也介绍过Deque可以做为栈来使用。今天我们介绍一种PriorityQueue，可以安装对象的自然顺序或者自定义顺序在Queue中进行排序。 PriorityQueue

文章目录 PriorityBlockingQueue概述类图结构及重要字段什么是二叉堆堆的基本操作向上调整void up(int u)向下调整void down(int u) 构造器扩容方法tryGrow源码中向上调整和向下调整实现siftUpComparablesiftDownComparable heapify建堆or堆化put非阻塞式插入take阻塞式获取remove移除指定元素总结参

类的描述 public class PriorityBlockingQueue<E>extends AbstractQueue<E>implements BlockingQueue<E>, Serializable 使用与类PriorityQueue相同的排序规则（堆排序）并提供阻塞检索操作的无界阻塞队列。虽然此队列在逻辑上是无界的，但由于资源耗尽（导致OutOfMemoryError