PriorityBlockingQueue详解

PriorityBlockingQueue介绍

【1】PriorityBlockingQueue是一个无界的基于数组的优先级阻塞队列,数组的默认长度是11,也可以指定数组的长度,且可以无限的扩充,直到资源消耗尽为止,每次出队都返回优先级别最高的或者最低的元素。默认情况下元素采用自然顺序升序排序,当然我们也可以通过构造函数来指定Comparator来对元素进行排序。需要注意的是PriorityBlockingQueue不能保证同优先级元素的顺序。

【2】优先级队列PriorityQueue: 队列中每个元素都有一个优先级,出队的时候,优先级最高的先出。

PriorityBlockingQueue的源码分析

【1】属性值

【2】构造函数

【3】核心方法分析

1)核心扩容函数

2)入队方法

4)队列填入方式

代码展示

图解说明

1.利用了满二叉树的理念,(k – 1) >>> 1可以获得存入节点的父节点下标,然后进行比较。若判断应该上升,则将父节点置于k存储的地方。

2.重复循环,知道二叉树root节点,或者已经找到了合适的位置

4)出队方法

5)队列修正方式

代码展示

图解说明

1.采用尾结点代替头节点,然后利用下沉的方式来修正优先队列里面的数据。

2.下沉限制在倒数第二层,以为倒数第二层就会与倒数第一层进行比较了,所以应该进行限制(下标位置超出倒数第二层的最大下标就应该停止了)

3.其次看的时候,可以把左右子树都当做一个小的满二叉树,不断逐层划分,这样条理更清晰。

PriorityBlockingQueue总结

【1】 一个支持优先级排序的无界阻塞队列,优先级高的先出队,优先级低的后出队

【2】数据结构:数组+二叉堆(默认容量11,可指定初始容量,会自动扩容,最大容量是(Integer.MAX_VALUE – 8))

【3】锁:ReentrantLock,存取是同一把锁

【4】阻塞对象:NotEmpty,出队,队列为空时阻塞

【5】入队,不阻塞,永远返回成功,无界;根据比较器进行堆化(排序)自下而上,如果比较器为 null,则按照自然顺序排序,传入比较器对象就按照比较器的顺序排序。

【6】出队,优先级最高的元素在堆顶(弹出堆顶元素),弹出前比较两个子节点再进行堆化(自上而下)。

【7】应用场景:1.业务办理排队叫号,VIP客户插队;2.电商抢购活动,会员级别高的用户优先抢购到商品;

Original: https://www.cnblogs.com/chafry/p/16783035.html
Author: 忧愁的chafry
Title: PriorityBlockingQueue详解

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/712146/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球