Netty源码解析之异步处理(二):盛赞Promise中的集合设计
前言
在阅读Netty源码的过程中,我越来越相信一句话:“Netty的源码非常好,质量极高,是Java中质量最高的开源项目之一”。如果认真研究,会有一种遍地黄金的感觉。
本篇文件我将记录一下鄙人在Promise的实现类DefaultPromise中发现的一块黄金:即用来存储监听器的集合的设计。
问题引入
接上文《Netty源码解析之异步处理(一):Promise系列的源码与实现原理》,在使用Promise时,可以往Promise里面加多个监听器。那么在Promise中改用什么集合来保存已经添加的监听器呢?
我认为大部分程序员都会使用一个Set或List等集合来存储,Netty则认为这些统统不合适,使用了自定义的DefaultFutureListeners集合来存储。
Promise中的集合设计
奇怪的listeners属性
在DefaultPromise源码中,用来存储监听器的属性是一个Object类型的listeners。乍看会觉得很奇怪,因为Promise中的监听器可能不止一个,用一个非集合的listeners如何存储?
DefaultPromise源码中的listeners
//用来存储添加到Promise中的监听器
private Object listeners;
单个监听器添加部分的源码
为了解答上面的疑问,需要看下DefaultPromise中添加单个监听器部分的源码,位于addListener0(GenericFutureListener listener) 方法中。
private void addListener0(GenericFutureListener<? extends Future<? super V>> listener) {//当listeners == null时,表示是第一次添加监听器if (listeners == null) {listeners = listener;//等到第三次添加时,listeners已经是DefaultFutureListeners对象//因此走了这一步} else if (listeners instanceof DefaultFutureListeners) {((DefaultFutureListeners) listeners).add(listener);//当listeners != null,表示已经不是第一次添加//如果是第二次添加的话,listeners此时是一个监听器GenericFutureListener的实例,//因此,第二次添加的话,走这一步,创建DefaultFutureListeners实例赋值给listeners} else {listeners = new DefaultFutureListeners((GenericFutureListener<?>) listeners, listener);}}
从上面的源码中,我们可以看出,添加单个监听器分为三种方式:
1、第一次添加监听器时,直接把监听器,即GenericFutureListener类型的实例赋值给DefaultPromise中用来存储监听器的listeners属性。
2、第二次添加监听器时,创建了DefaultFutureListeners集合的对象,并且将两次添加的监听器作为参数传递。
然后,我们进入DefaultFutureListeners的构造方法。
DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first, GenericFutureListener<? extends Future<?>> second) {//创建一个长度为2的数组listeners = new GenericFutureListener[2];//将第一次和第二次添加的两个监听器存入数组中listeners[0] = first;listeners[1] = second;//数组长度为2size = 2;//如果添加的监听器是进度监听器,progressiveSize自增1if (first instanceof GenericProgressiveFutureListener) {progressiveSize ++;}if (second instanceof GenericProgressiveFutureListener) {progressiveSize ++;}}
可以发现,在DefaultFutureListeners的构造方法中,创建一个长度为2的数组listeners,然后将第一次和第二次添加的两个监听器存入数组中。这时候,可以说两个监听器已经存储在DefaultFutureListeners集合中。
3、等到第三次或第三次以后添加时,调用DefaultFutureListeners的add方法将监听器存入集合。
在DefaultFutureListeners的add方法中,进行了检查数组长度和监听器插入数组等操作,没什么特别的。
public void add(GenericFutureListener<? extends Future<?>> l) {GenericFutureListener<? extends Future<?>>[] listeners = this.listeners;//获取当前集合中元素的数量final int size = this.size;//如果当前集合中元素的数量等于数组长度//说明本次添加时,数组长度就不足,因此数组需要扩容if (size == listeners.length) {//数组扩容,先用左移位将新数组长度设为原数组长度的两倍//然后使用数组拷贝的方式得到新数组this.listeners = listeners = Arrays.copyOf(listeners, size << 1);}//将监听器插入数组中listeners[size] = l;//集合中元素数量增加1this.size = size + 1;//如果本次添加的是进度监听器,progressiveSize也自增1if (l instanceof GenericProgressiveFutureListener) {progressiveSize ++;}}
Promise中集合设计的思考
为什么要这么设计?
刚开始我觉得非常奇怪,
1、为什么不直接把DefaultPromise源码中的listeners属性设为一个ArrayList类型的集合,而是要兜了一圈才用集合?
2、为什么DefaultFutureListeners创建后,其内部的数组长度只有2?多给点初始长度不是能避免数组扩容吗?
后来我在不断地阅读Netty源码时发现,在几乎全部的Promise实际使用场景中,添加的监听器数量很少,同一个Promise在大部分情况下只用了1个监听器,很少数情况下用了2个监听器,用到3个监听器的情况从未见过。
基于这种实际情况,如果刚开始就创建一个集合,甚至给集合中的数组分配一定的初始长度的话,在性能和存储空间上都是浪费!因为在大部分场景下一个Promise只包含1个监听器,所以直接把这一个监听器赋值给listeners属性是最好的选择。如果遇到了极少数的需要包含2个监听器的情况,那也只创建一个长度为2的数组来保存,因为监听器再多的情况几乎没有,这样避免空间浪费。
这种设计和编码方式叫做“启发式编程”。
使用栈可不可以?
我也想过Promise的监听器使用栈这种数据结构来存储是否可以,这样的话我们只要在监听器GenericFutureListener中定义一个next属性,用来指向下一个监听器即可,编码更加简洁和方便。
我认为可以,但是性能不如数组。因为在Promise的源码中,存储的监听器最多的使用场景就是遍历全部然后触发。因为数组在内存中是连续的,正好可以利用计算机的局部性原理,能让CPU缓存把本身就很小的数组全部读入,进而能以最快的速度进行遍历。而栈使用的是链表结构,链表的节点是分散在堆空间里面的,很难使用到CPU缓存。
数组与CPU缓存的详细关联请参考:https://www.cnblogs.com/ajuanabc/archive/2009/03/28/2462628.html
相关文章:
Netty源码解析之异步处理(二):盛赞Promise中的集合设计
前言 在阅读Netty源码的过程中,我越来越相信一句话:“Netty的源码非常好,质量极高,是Java中质量最高的开源项目之一”。如果认真研究,会有一种遍地黄金的感觉。 本篇文件我将记录一下鄙人在Promise的实现类DefaultPr…...
NetworkX布局算法:nx.spring_layout
诸神缄默不语-个人CSDN博文目录 官方文档:https://networkx.org/documentation/stable/reference/generated/networkx.drawing.layout.spring_layout.html 和nx.fruchterman_reingold_layout()等价。 这个函数主要是为了在可视化NetworkX图时设置节点分布布局的&…...
Navicat导入海量Excel数据到数据库(简易介绍)
目录 前言正文 前言 此处主要作为科普帖进行记录 原先Java处理海量数据的导入时,由于接口超时,数据处理不过来,后续转为Navicat Navicat 是一款功能强大的数据库管理工具,支持多种数据库系统(如 MySQL、PostgreSQL、…...
LeetCodehot100 力扣热题100 二叉树展开为链表
代码思路 目标: 将二叉树展平(flatten)为一个单链表。展平后的链表应该按照前序遍历的顺序排列节点,即: • 节点的左子树指针设置为 nullptr。 • 节点的右子树指针指向下一个节点。 代码注释及思路 class Solution…...
2.14学习总结
#include <stdio.h> #include <stdlib.h> #include <math.h>#define MAX_N 32767// 二分查找最接近目标值的元素 int binarySearch(int* arr, int left, int right, int target) {while (left < right) {int mid left (right - left) / 2;if (arr[mid] …...
在WPS中通过JavaScript宏(JSA)调用本地DeepSeek API优化文档教程
既然我们已经在本地部署了DeepSeek,肯定希望能够利用本地的模型对自己软件开发、办公文档进行优化使用,接下来就先在WPS中通过JavaScript宏(JSA)调用本地DeepSeek API优化文档的教程奉上。 前提: (1)已经部署好了DeepSeek,可以看我的文章:个人windows电脑上安装DeepSe…...
zola + github page,用 workflows 部署
之前的Zola都是本地build之后,再push到github上,这种方式很明显的弊端就是只能在本地编辑,而不能通过github编辑,再pull到本地,缺乏了灵活性。因此将zola用workflows来部署。 repo地址:https://github.com/…...
【科技革命】颠覆性力量与社会伦理的再平衡
目录 2025年科技革命:颠覆性力量与社会伦理的再平衡目录技术突破全景图认知智能的范式转移量子霸权实现路径生物编程技术革命能源结构重构工程 产业生态链重构医疗健康新范式教育系统智能进化金融基础设施变革制造范式革命 科技伦理与文明演进 2025年科技革命&#…...
UIView 与 CALayer 的联系和区别
今天说一下UIView 与 CALayer 一、UIView 和 CALayer 的关系 在 iOS 开发中,UIView 是用户界面的基础,它负责处理用户交互和绘制内容,而 CALayer 是 UIView 内部用于显示内容的核心图层(Layer)。每个 UIView 内部都有…...
Jenkins 新建配置 Freestyle project 任务 六
Jenkins 新建配置 Freestyle project 任务 六 一、新建任务 在 Jenkins 界面 点击 New Item 点击 Apply 点击 Save 回到任务主界面 二、General 点击左侧 Configure Description:任务描述 勾选 Discard old builds Discard old builds:控制何时…...
深入解析A2DP v1.4协议:蓝牙高质量音频传输的技术与实现
1. A2DP概述 A2DP(Advanced Audio Distribution Profile)是一种高质量音频流媒体协议,旨在实现高质量音频内容的分发,通常用于通过蓝牙设备传输音频数据,例如将音乐从便携式播放器传输到耳机或扬声器。与传统的蓝牙语…...
mybatis-plus逆向code generator pgsql实践
mybatis-plus逆向code generator pgsql实践 环境准备重要工具的版本供参考pom依赖待逆向的SQL 配置文件CodeGenerator配置类配置类说明 环境准备 重要工具的版本 jdk1.8.0_131springboot 2.7.6mybatis-plus 3.5.7pgsql 14.15 供参考pom依赖 <?xml version"1.0&quo…...
Android Studio:RxBus结合ICompositeSubscription使用
我现在想用 RxBus 来发布和订阅事件,同时使用 ICompositeSubscription 来管理订阅。跟前一个博客的区别在于,事件流的产生方式不同,更加得全面。 目标 使用 RxBus 发布事件。使用 ICompositeSubscription 来管理订阅。在 Activity 中创建订…...
微软AutoGen高级功能——Magentic-One
介绍 大家好,博主又来给大家分享知识了,这次给大家分享的内容是微软AutoGen框架的高级功能Magentic-One。那么它是用来做什么的或它又是什么功能呢,我们直接进入正题。 Magentic-One Magnetic-One是一个通用型多智能体系统,用于…...
redis cluster测试
集群节点信息这时候停掉一个master 172.30.60.31 从集群信息集中我们可以看到172.30.60.31的slave是172.30.60.41,查看41的日志,发现他成为了新的master 这时候我们在将172.30.60.41也杀死,会发现集群异常了 尝试把172.30.60.31启动ÿ…...
【ARM】JTAG接口介绍
1、 文档目标 对 JTAG 接口有更多的认识,在遇到关于 JTAG 接口问题时有一些排查的思路。 2、 问题场景 在使用调试器过程时,免不了要接触到 JTAG 接口,当出现连接不上时,就不知道从哪来进行排查。 3、软硬件环境 1 软件版本&am…...
处理项目中存在多个版本的jsqlparser依赖
异常提示 Correct the classpath of your application so that it contains a single, compatible version of net.sf.jsqlparser.statement.select.SelectExpressionIte实际问题 原因:项目中同时使用了 mybatis-plus 和 pagehelper,两者都用到了 jsqlpa…...
部署 DeepSeek R1各个版本所需硬件配置清单
DeepSeek-R1 通过其卓越的推理性能和灵活的训练机制,在 2025 年的春节期间受到了广泛关注。 DeepSeek-R1 是一款高性能的 AI 推理模型,主要通过强化学习技术来增强模型在复杂任务场景下的推理能力。 在本地部署 DeepSeek-R1 时,尤其是完整的…...
数据结构:Map Set(一)
目录 一、搜索树 1、概念 2、查找 3、插入 4、删除 二、搜索 1、概念及场景 2、模型 (1)纯key模型 (2)Key-Value模型 三、Map的使用 1、什么是Map? 2、Map的常用方法 (1)V put(K …...
zabbix 监控系统 配置钉钉告警
步骤1:创建钉钉群 步骤2:创建机器人 点击群设置 然后下划选择机器人。 点击添加机器人 选择自定义机器人 点击添加 1、设置机器人的名字和群组 2、设置自定义关键字 zabbix 告警 报警 恢复 3、点击我已阅读并同意 4、点击完成 生成webhook 链接 注…...
wordpress后台更新后 前端没变化的解决方法
使用siteground主机的wordpress网站,会出现更新了网站内容和修改了php模板文件、js文件、css文件、图片文件后,网站没有变化的情况。 不熟悉siteground主机的新手,遇到这个问题,就很抓狂,明明是哪都没操作错误&#x…...
RocketMQ延迟消息机制
两种延迟消息 RocketMQ中提供了两种延迟消息机制 指定固定的延迟级别 通过在Message中设定一个MessageDelayLevel参数,对应18个预设的延迟级别指定时间点的延迟级别 通过在Message中设定一个DeliverTimeMS指定一个Long类型表示的具体时间点。到了时间点后…...
树莓派超全系列教程文档--(61)树莓派摄像头高级使用方法
树莓派摄像头高级使用方法 配置通过调谐文件来调整相机行为 使用多个摄像头安装 libcam 和 rpicam-apps依赖关系开发包 文章来源: http://raspberry.dns8844.cn/documentation 原文网址 配置 大多数用例自动工作,无需更改相机配置。但是,一…...
STM32F4基本定时器使用和原理详解
STM32F4基本定时器使用和原理详解 前言如何确定定时器挂载在哪条时钟线上配置及使用方法参数配置PrescalerCounter ModeCounter Periodauto-reload preloadTrigger Event Selection 中断配置生成的代码及使用方法初始化代码基本定时器触发DCA或者ADC的代码讲解中断代码定时启动…...
Spring AI与Spring Modulith核心技术解析
Spring AI核心架构解析 Spring AI(https://spring.io/projects/spring-ai)作为Spring生态中的AI集成框架,其核心设计理念是通过模块化架构降低AI应用的开发复杂度。与Python生态中的LangChain/LlamaIndex等工具类似,但特别为多语…...
Device Mapper 机制
Device Mapper 机制详解 Device Mapper(简称 DM)是 Linux 内核中的一套通用块设备映射框架,为 LVM、加密磁盘、RAID 等提供底层支持。本文将详细介绍 Device Mapper 的原理、实现、内核配置、常用工具、操作测试流程,并配以详细的…...
【分享】推荐一些办公小工具
1、PDF 在线转换 https://smallpdf.com/cn/pdf-tools 推荐理由:大部分的转换软件需要收费,要么功能不齐全,而开会员又用不了几次浪费钱,借用别人的又不安全。 这个网站它不需要登录或下载安装。而且提供的免费功能就能满足日常…...
C++:多态机制详解
目录 一. 多态的概念 1.静态多态(编译时多态) 二.动态多态的定义及实现 1.多态的构成条件 2.虚函数 3.虚函数的重写/覆盖 4.虚函数重写的一些其他问题 1).协变 2).析构函数的重写 5.override 和 final关键字 1&#…...
GitFlow 工作模式(详解)
今天再学项目的过程中遇到使用gitflow模式管理代码,因此进行学习并且发布关于gitflow的一些思考 Git与GitFlow模式 我们在写代码的时候通常会进行网上保存,无论是github还是gittee,都是一种基于git去保存代码的形式,这样保存代码…...
JavaScript 数据类型详解
JavaScript 数据类型详解 JavaScript 数据类型分为 原始类型(Primitive) 和 对象类型(Object) 两大类,共 8 种(ES11): 一、原始类型(7种) 1. undefined 定…...
