PriorityQueue 阅读记录

1、前言

1、优先队列,底层通过数组来构造树(二叉树) 来实现的。

2、默认是最小堆(取出来的是最小值),可以通过传入一个比较器 comparator 来构造一个最大堆。

3、传入的参数不能为空,否则抛出NPE问题。

4、最大堆的特性是左右孩子的值都比父节点小, 最小堆是左右节点值都比父节点大,利用该特性可以用来解决一些topK问题

2、关键常量
// 初始化容量
private static final int DEFAULT_INITIAL_CAPACITY = 11;

// 最小堆和最大堆的比较器, 默认是最小堆
private final Comparator<? super E> comparator;

// 数据存储的数组,构造成树后,节点在数组的index 可以通过以下公式求出
// leftNo = parentNo*2+1  左节点的index
// rightNo = parentNo*2+2 右节点的index
// parentNo = (nodeNo-1)/2 //父节点的index , nodeNo当前节点的index
transient Object[] queue;

// 最大数组可分配的大小, 这里 - 8 是因为一些虚拟机在数组中会保留头部字段,
// 如果不 -8,分配大小的时候有可能导致OutOfMemoryError
private static final int MAX_ARRAY_SIZE = Integer.MAX_VALUE - 8;
3、源码解析

下边记录下对一些方法的理解。

3.1、扩容
   /**
     * 扩容
     *
     * @param minCapacity 期望的最小容量
     */
    private void grow(int minCapacity) {
        int oldCapacity = queue.length;
        // 扩容两倍,如果还是小,那么而外加 50%
        int newCapacity = oldCapacity + ((oldCapacity < 64) ?
                                         (oldCapacity + 2) :
                                         (oldCapacity >> 1));
        // 防止新容量大于数组的最大容量
        if (newCapacity - MAX_ARRAY_SIZE > 0)
            newCapacity = hugeCapacity(minCapacity);
        queue = Arrays.copyOf(queue, newCapacity);
    }

 	private static int hugeCapacity(int minCapacity) {
        if (minCapacity < 0) // 最小容量 < 0 ,抛出异常
            throw new OutOfMemoryError();
        return (minCapacity > MAX_ARRAY_SIZE) ?
            Integer.MAX_VALUE :
            MAX_ARRAY_SIZE;
    }
3.2、add 方法
public boolean add(E e) {
        return offer(e);
    }
	
	/**
     * 入队,不能插入 null 元素
     */
	public boolean offer(E e) {
        // 传入null元素,抛异常
        if (e == null)
            throw new NullPointerException();
        modCount++;
        int i = size;
        // 如果当前容量大于数组长度,扩容
        if (i >= queue.length)
            grow(i + 1);
        size = i + 1;
        // 如果当前容量为空,表示为新队列,直接放在首位即可
        if (i == 0)
            queue[0] = e;
        // 否则直接插入,调整,保证堆的合理性
        else
            siftUp(i, e);
        return true;
    }
	
	/**
     * 插入值后,根据比较器进行结构调整,维持堆的特性,向上调整
     */
	 private void siftUp(int k, E x) {
        if (comparator != null)
            siftUpUsingComparator(k, x);
        else
            siftUpComparable(k, x);
    }

	/**
     * 最小堆的结构调整,从k指定的位置开始,
     * 将x逐层与当前点的parent进行比较并交换,直到满足x >= queue[parent]为止。
     * 注意这里的比较可以是元素的自然顺序,也可以是依靠比较器的顺序。
     */
	private void siftUpComparable(int k, E x) {
        Comparable<? super E> key = (Comparable<? super E>) x;
        // k 指定的位置index
        while (k > 0) {
            // 根据公式求出 parentNo = (nodeNo-1)/2 父节点的 index
            int parent = (k - 1) >>> 1;
            Object e = queue[parent];
            // 从k当前位置的parent进行值比较,如果x 大于 parent 就停止循环。(最小堆子节点不能小于父节点)
            if (key.compareTo((E) e) >= 0)
                break;
            // 交换值
            queue[k] = e;
            k = parent;
        }
        queue[k] = key;
    }
	
	/*
     * @link siftUpComparable() 方法差不多,根据传入比较器值的大小来进行堆的结构调整
     * 可能是最大堆,也可能是最小堆
     */
 	private void siftUpUsingComparator(int k, E x) {
        while (k > 0) {
            int parent = (k - 1) >>> 1;
            Object e = queue[parent];
            // 用比较器的比较方法进行比较
            if (comparator.compare(x, (E) e) >= 0)
                break;
            queue[k] = e;
            k = parent;
        }
        queue[k] = x;
    }

关于堆siftUp的结构调整,如下图所示:(图来自https://github.com/CarpenterLee/JCFInternals/blob/master/markdown/8-PriorityQueue.md)

 3.3、peek()
    // 获取堆顶元素
	public E peek() {
        return (size == 0) ? null : (E) queue[0];
    }
3.4、poll()
 /*
     * 弹出堆的第一个元素,同时将最后一个元素置 null , 然后进行堆的结构调整,向下调整。
     */
	public E poll() {
        if (size == 0)
            return null;
        int s = --size;
        modCount++;
        // 获取堆第一个元素
        E result = (E) queue[0];
        // 获取堆最后一个元素,将其置null
        E x = (E) queue[s];
        queue[s] = null;
        // 堆的结构调整
        if (s != 0)
            siftDown(0, x);
        return result;
    }

	 /**
     * 插入 x 的值放在 k 的位置上,为了保证堆的特性,根据比较器来进行调整堆的结构。
     * 
     * @param k 要插入的位置
     * @param x 要插入的值
     */
    private void siftDown(int k, E x) {
        if (comparator != null)
            siftDownUsingComparator(k, x);
        else
            siftDownComparable(k, x);
    }

    /*
     * 堆结构向下调整,从k指定的位置开始,
     * 将x逐层向下与当前点的左右孩子中较小的那个交换,直到x小于或等于左右孩子中的任何一个为止。
     */
    private void siftDownComparable(int k, E x) {
        Comparable<? super E> key = (Comparable<? super E>)x;
        // 获取数组的中点位置
        int half = size >>> 1;        // loop while a non-leaf
        while (k < half) {
            // 获取k左孩子的index(假设左孩子是最小的)
            int child = (k << 1) + 1; 
            Object c = queue[child];
            // 获取k右孩子的index, 为左孩子index + 1
            int right = child + 1;
            // 将 x 逐层向下与当前点的左右孩子中较小的那个交换,
            // 直到 x 小于或等于左右孩子中的任何一个为止
            if (right < size &&
                ((Comparable<? super E>) c).compareTo((E) queue[right]) > 0)
                // 左右孩子最小节点的值
                c = queue[child = right];
            // 如果父节点比孩子节点还小,则结束循环
            if (key.compareTo((E) c) <= 0)
                break;
            // 交互当前父节点和比较小节点的值
            queue[k] = c;
            // 记录孩子节点的index, 继续循环
            k = child;
        }
        // 最终把k节点,也就是父节点放在合适的位置上,维持堆的特性
        queue[k] = key;
    }

    /*
     * 根据用户构造的比较器,向下调整堆结构,从k指定的位置开始,
     * 将x逐层向下与当前点的左右孩子中较小的那个交换,直到x小于或等于左右孩子中的任何一个为止。
     */
    private void siftDownUsingComparator(int k, E x) {
        // 获取数组的中点位置
        int half = size >>> 1;
        while (k < half) {
            int child = (k << 1) + 1;
            Object c = queue[child];
            int right = child + 1;
            if (right < size &&
                // 使用用户自定义的比较器进行比较
                comparator.compare((E) c, (E) queue[right]) > 0)
                c = queue[child = right];
            if (comparator.compare(x, (E) c) <= 0)
                break;
            // 交换值
            queue[k] = c;
            k = child;
        }
        queue[k] = x;
    }

 关于堆的向下调整大概图,如下所示:(图来着https://github.com/CarpenterLee/JCFInternals/blob/master/markdown/8-PriorityQueue.md)

3.5、remove()
// 删除元素,如果元素不存在,返回false
	public boolean remove(Object o) {
        int i = indexOf(o);
        if (i == -1)
            return false;
        else {
            removeAt(i);
            return true;
        }
    }
	
	// 遍历查找元素是否存在于队列中,存在则返回其索引 ,否则返回-1
	private int indexOf(Object o) {
        if (o != null) {
            for (int i = 0; i < size; i++)
                if (o.equals(queue[i]))
                    return i;
        }
        return -1;
    }
	
	// 根据索引删除元素
	private E removeAt(int i) {
        // 假设索引大于等于0, 同时索引小于数组大小
        modCount++;
        int s = --size;
        // 如果元素刚好是最后一个,直接置 null 即可
        if (s == i)
            queue[i] = null;
        else {
            // 找到最后的一个元素,保存最后一个元素的值,然后删除该值
            E moved = (E) queue[s];
            queue[s] = null;
            // 这时候需要向下调整堆的结构
            siftDown(i, moved);
            // 如果当前索引i的值还等于调整前最后一个元素的值
            if (queue[i] == moved) {
                // 向上调整
                siftUp(i, moved);
                // 调整完之后,如果当前索引i的值不等于调整前最后一个元素的值
                if (queue[i] != moved)
                    // 返回删除的元素的值
                    return moved;
            }
        }
        // 没找到,返回null
        return null;
    }

remove(i)堆调整的大概图如下所示:(图来自https://github.com/CarpenterLee/JCFInternals/blob/master/markdown/8-PriorityQueue.md)

手动结束线~~~~~~~

对于其它方法,感兴趣的朋友可以自行去研究下。

4、参考

JCFInternals/markdown/8-PriorityQueue.md at master · CarpenterLee/JCFInternals · GitHub大佬的集合源码分析,写的很nice,图都来自这上面的。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/802272.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

系统架构设计师教程 第3章 信息系统基础知识-3.1 信息系统概述

系统架构设计师教程 第3章 信息系统基础知识-3.1 信息系统概述 3.1.1 信息系统的定义3.1.1.1 信息系统3.1.1.2 信息化3.1.2 信息系统的发展3.1.2.1 初始阶段3.1.2.2 传播阶段3.1.2.3 控制阶段3.1.2.4 集成阶段3.1.2.5 数据管理阶段3.1.2.6 成熟阶段3.1.3 信息系统的分类3.…

读人工智能全传15意向立场

1. 物理立场 1.1. 可以解释一个实体行为 1.2. 在物理立场中&#xff0c;我们使用自然法则(物理、化学等)来预测系统的行为结果 1.3. 虽然物理立场在解释这种行为的时候非常有效&#xff0c;但无法应用于理解或者预测人类行为 1.3.1. …

六边形动态特效404单页HTML源码

源码介绍 动态悬浮的六边形,旁边404文字以及跳转按钮,整体看着像科技二次元画风,页面简约美观,可以做网站错误页或者丢失页面,将下面的代码放到空白的HTML里面,然后上传到服务器里面,设置好重定向即可 效果预览 完整源码 <!DOCTYPE html> <html><head…

关于springboot的@DS(““)多数据源的注解无法生效的原因

对于com.baomidou.dynamic.datasource.annotation的DS注解&#xff0c;但凡有一个AOP的修改都会影响到多数据源无法生效的问题&#xff0c;本次我是添加了方法上添加了Transactional&#xff0c;例如下图&#xff1a; 在方法上写了这个注解&#xff0c;会影响到DS("db2&qu…

万字长文之分库分表里如何优化分页查询?【后端面试题 | 中间件 | 数据库 | MySQL | 分库分表 | 分页查询】

分库分表的一般做法 一般会使用三种算法&#xff1a; 哈希分库分表&#xff1a;根据分库分表键算出一个哈希值&#xff0c;根据这个哈希值选择一个数据库。最常见的就是数字类型的字段作为分库分表键&#xff0c;然后取余。比如在订单表里&#xff0c;可以按照买家的ID除以8的…

【PB案例学习笔记】-32制作一个简单记事本程序

大家好&#xff0c;我是晓凡。 写在前面 这是PB案例学习笔记系列文章的第32篇&#xff0c;该系列文章适合具有一定PB基础的读者。 通过一个个由浅入深的编程实战案例学习&#xff0c;提高编程技巧&#xff0c;以保证小伙伴们能应付公司的各种开发需求。 文章中设计到的源码…

Web3D:WebGL为什么在渲染性能上输给了WebGPU。

WebGL已经成为了web3D的标配&#xff0c;市面上有N多基于webGL的3D引擎&#xff0c;WebGPU作为挑战者&#xff0c;在渲染性能上确实改过webGL一头&#xff0c;由于起步较晚&#xff0c;想通过这个优势加持&#xff0c;赶上并超越webGL仍需时日。 贝格前端工场为大家分享一下这…

leetcode 1459 矩形面积(postgresql)

需求 表: Points ---------------------- | Column Name | Type | ---------------------- | id | int | | x_value | int | | y_value | int | ---------------------- id 是该表主键 每个点都用二维坐标 (x_value, y_value) 表示 写一个 SQL 语句&#xff0c;报告由表中任…

Redis-基础概念

目录 概念 Redis是什么 Redis 和 MySQL 的区别&#xff1f; Redis单线程有什么极端场景的瓶颈 Redis为什么快? 为什么Redis是单线程? Redis是单线程还是多线程 Redis为什么选择单线程做核心处理 Redis6.0之后引入了多线程&#xff0c;你知道为什么吗? 瓶颈是内存和I…

MySQL-事务、日志

事务 特性 原子性 是指事务开始后&#xff0c;必须成功执行完所有的操作才会结束&#xff0c;否则会回滚到事务刚开始前。 拿转账来说&#xff0c;一个成功的 A向B转账100元的过程 会涉及如下过程&#xff1a; A&#xff1a;从数据库读取A的余额&#xff1b;A的余额-100&am…

Pytorch学习笔记day1—— 安装教程

这里写自定义目录标题 Pytorch安装方式 工作需要&#xff0c;最近开始搞一点AI的事情。但是这个国产的AI框架&#xff0c;实话说对初学者不太友好 https://www.mindspore.cn/ 比如说它不支持win下的CUDA&#xff0c;可是我手里只有3070Ti和4060也不太可能自己去买昇腾就有点绷不…

C. Alternating Subsequence[双指针,贪心]

题目描述&#xff1a; 思路分析&#xff1a;题目俩要求&#xff0c;最长&#xff0c;值最大&#xff0c;异号&#xff0c;保证异号的情况是找到最长而且尽可能大&#xff0c;其实很容易想到&#xff0c;一开始先把第一个数单独放进去&#xff0c;保证不浪费任何一个元素&#…

迈克尔的44岁:时间的感悟与人生的智慧

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗&#xff1f;订阅我们的简报&#xff0c;深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同&#xff0c;从行业内部的深度分析和实用指南中受益。不要错过这个机会&#xff0c;成为AI领…

【JavaEE】HTTP(2)

&#x1f921;&#x1f921;&#x1f921;个人主页&#x1f921;&#x1f921;&#x1f921; &#x1f921;&#x1f921;&#x1f921;JavaEE专栏&#x1f921;&#x1f921;&#x1f921; &#x1f921;&#x1f921;&#x1f921;下一篇文章&#xff1a;【JavaEE】HTTP协议(…

短链接day8

短链接监控 开发访问单个短链接监控统计功能 不知道是哪里复制错了&#xff0c;反正就是一顿报错&#xff0c;改了这个又改那个&#xff0c;还是报错。。暂时不管了。 记录短链接访问日志 logdo新增networt、device、local属性。 分页查询短链接访问日志 分页查询短链接今…

Qt 多语言

记录Qt多语言的实现过程 目录 1.项目配置文件.pro配置 2.程序中的字符串用tr()封装 3.生成翻译文件 4.使用Qt语言家修改翻译文件 4.1使用Qt语言家打开 4.2 .更改文件配置 5. 生成qm文件 6.代码执行切换语言 6.1入口处 6.2 事件执行 0.效果 1.项目配置文件.pro配置 T…

集合媒体管理、分类、搜索于一体的开源利器:Stash

Stash&#xff1a;强大的媒体管理工具&#xff0c;让您的影音生活井井有条- 精选真开源&#xff0c;释放新价值。 概览 Stash是一个专为个人媒体管理而设计的开源工具&#xff0c;基于 Go 编写&#xff0c;支持自部署。它以用户友好的界面和强大的功能&#xff0c;满足了现代用…

2024华为数通HCIP-datacom最新题库(变题更新⑥)

请注意&#xff0c;华为HCIP-Datacom考试831已变题 请注意&#xff0c;华为HCIP-Datacom考试831已变题 请注意&#xff0c;华为HCIP-Datacom考试831已变题 近期打算考HCIP的朋友注意了&#xff0c;如果你准备去考试&#xff0c;还是用的之前的题库&#xff0c;切记暂缓。 1、…

ModuleNotFoundError: No module named ‘_cffi_backend‘的二中情况解决方案

1、问题概述? 创作时间:2024年7月 在pycharm中执行python脚本出现如下问题: No module named _cffi_backend 主要说明二中情况: 第一种原因:最常见的原因就是没有安装cffi模块,我们通过命令安装就可以了。 第二种原因:不常见的原因,如果你在pycharm中运行了别人的…

【UE5.1】NPC人工智能——02 NPC移动到指定位置

效果 步骤 1. 新建一个蓝图&#xff0c;父类选择“AI控制器” 这里命名为“BP_NPC_AIController”&#xff0c;表示专门用于控制NPC的AI控制器 2. 找到我们之前创建的所有NPC的父类“BP_NPC” 打开“BP_NPC”&#xff0c;在类默认值中&#xff0c;将“AI控制器类”一项设置为“…