高并发内存池(16)-三层缓存的回收过程

内存池的回收过程是内存管理系统的关键环节,它通过分层协作智能合并机制,确保内存高效重复利用。以下是完整的回收流程解析:


一、回收触发场景

  1. ThreadCache回收:线程释放小对象(≤256KB)
  2. CentralCache回收:ThreadCache批量返还或Span完全空闲
  3. PageCache回收:CentralCache返还完整Span

二、三级回收流程

1. ThreadCache层级(无锁)
// ThreadCache释放单个对象
void Deallocate(void* ptr, size_t size) {FreeList* list = GetFreeList(size);list->Push(ptr);  // 头插法插入自由链表// 如果自由链表过长,批量返还CentralCacheif (list->Size() >= list->MaxSize()) {void* start, *end;size_t batchNum = list->PopRange(start, end, list->MaxSize()/2);CentralCache::ReleaseListToSpans(start, size);}
}

特点

  • 线程本地操作无锁竞争
  • 批量返还减少锁开销(如每次返还50%的对象)
  • 自由链表采用头插法(O(1)时间复杂度)

2. CentralCache层级(桶锁)
// CentralCache接收ThreadCache返还的内存块
void ReleaseListToSpans(void* start, size_t size) {size_t index = SizeClass::Index(size);_spanLists[index]._mtx.lock();  // 加桶锁while (start) {void* next = NextObj(start);Span* span = PageCache::MapObjectToSpan(start);  // 找到所属Span// 头插法归还到Span的自由链表NextObj(start) = span->_freeList;span->_freeList = start;span->_useCount--;// 如果Span完全空闲,返还PageCacheif (span->_useCount == 0) {_spanLists[index].Erase(span);PageCache::ReleaseSpanToPageCache(span);  // 触发合并}start = next;}_spanLists[index]._mtx.unlock();
}

关键点

  • 桶锁粒度:不同size的SpanList有独立锁,减少竞争
  • 引用计数:通过_useCount判断Span是否完全空闲
  • 批量处理:一次处理多个对象,减少锁持有时间

3. PageCache层级(全局锁)
// PageCache合并空闲Span
void ReleaseSpanToPageCache(Span* span) {std::lock_guard<std::mutex> lock(_pageMtx);// 向前合并(检查前一页是否空闲)while (MergePrevSpan(span)) {}// 向后合并(检查后一页是否空闲)while (MergeNextSpan(span)) {}// 插入对应大小的SpanList_spanLists[span->_n].PushFront(span);// 更新页号映射(首尾页都指向该Span)_idSpanMap[span->_pageId] = span;_idSpanMap[span->_pageId + span->_n - 1] = span;
}

合并算法

bool MergePrevSpan(Span* span) {PAGE_ID prevId = span->_pageId - 1;auto it = _idSpanMap.find(prevId);if (it == _idSpanMap.end()) return false;Span* prevSpan = it->second;if (prevSpan->_isUse || prevSpan->_n + span->_n > 128) return false;// 执行合并span->_pageId = prevSpan->_pageId;span->_n += prevSpan->_n;_spanLists[prevSpan->_n].Erase(prevSpan);delete prevSpan;return true;
}

合并效果

[已用][空闲SpanA][空闲SpanB][已用]  
合并后→ [已用][大空闲Span][已用]

三、回收过程示意图

sequenceDiagramparticipant ThreadCacheparticipant CentralCacheparticipant PageCacheThreadCache->>CentralCache: 批量返还对象(带桶锁)CentralCache->>Span: 更新自由链表和引用计数alt Span完全空闲CentralCache->>PageCache: 返还Span(全局锁)PageCache->>PageCache: 尝试前后页合并PageCache->>空闲链表: 插入合并后的Spanend

四、设计精髓

  1. 分层缓冲

    • ThreadCache:线程独占,无锁
    • CentralCache:共享但分桶加锁
    • PageCache:全局锁但操作频率低
  2. 合并策略

    • 立即合并:发现相邻空闲Span立即合并
    • 双向检查:同时检查前后页,最大化合并机会
  3. 映射维护

    // 示例:合并后更新映射
    _idSpanMap[newSpan->_pageId] = newSpan;                // 首页
    _idSpanMap[newSpan->_pageId + newSpan->_n - 1] = newSpan; // 尾页
    
    • 确保通过任意页都能找到所属Span
  4. 锁粒度优化

    • ThreadCache:完全无锁
    • CentralCache:按size分桶加锁
    • PageCache:全局锁但操作较少

五、性能关键点

  1. 批量操作
    • ThreadCache攒够一批对象才返还CentralCache
    • CentralCache批量操作Span的自由链表
  2. 合并触发时机
    • 只在Span完全空闲时尝试合并
    • 避免频繁合并带来的开销
  3. 热点分离
    • 小对象高频操作走ThreadCache
    • 大对象低频操作走PageCache

六、异常处理

  1. 跨线程释放
    • 对象必须由分配它的线程释放(TLS机制保证)
    • 否则需要特殊处理(如加入全局释放队列)
  2. 内存泄漏检测
    • 通过_useCount判断未释放的内存
    • 定期扫描_idSpanMap检查泄漏

通过这种分层回收设计,内存池实现了:

  • 高频小对象分配/释放:无锁操作,性能接近O(1)
  • 大对象管理:系统级分配,避免碎片
  • 自适应合并:智能平衡内存利用率与合并开销

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

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

深入解析MyBatis Mapper接口工作原理

在Java持久层框架中&#xff0c;MyBatis以其灵活性和易用性赢得了广大开发者的青睐。作为MyBatis的核心概念之一&#xff0c;Mapper接口机制极大地简化了数据库操作代码的编写。本文将深入剖析MyBatis Mapper接口的工作原理&#xff0c;从基础概念到底层实现&#xff0c;帮助开…

疯狂星期四文案网第49天运营日记

网站运营第49天&#xff0c;点击观站&#xff1a; 疯狂星期四 crazy-thursday.com 全网最全的疯狂星期四文案网站 运营报告 今日访问量 常州苏州那些ip锲而不舍的扫了很多php的页面 今日搜索引擎收录情况 k页面比较严重了&#xff0c;哎。 我感觉不该做其他类型文案的 网…

从GPT-5发布来分析LLM大模型幻觉收敛(一)

GPT-5 号称在任何领域都有博士级别能力。在医疗健康领域&#xff0c;能够对专业的癌症诊断报告做通俗易懂的解读。对复杂的放射治疗方案决策&#xff0c;也能提供详细的分析报告&#xff0c;帮助病人权衡利弊。一位癌症患者的家属在发布会上表示&#xff0c;“ 真正鼓舞人心的是…

大模型安全概述、LlamaFirewall

资料搜集整理自网络。 概述 大模型爆火之后&#xff0c;衍生出大模型安全这一个比较新的领域。和之前的文章一样&#xff0c;本文有不少新颖的名词、概念、理论。 信通院、清华大学等多个单位联合发布的《大模型安全实践&#xff08;2024&#xff09;》&#xff0c;提出LLM安…

【目标检测】论文阅读3

Lightweight tomato ripeness detection algorithm based on the improved RT-DETR 论文地址 摘要 番茄具有很高的营养价值&#xff0c;需要对成熟果实进行准确的成熟度鉴定和选择性采收&#xff0c;以显著提高番茄收获管理的效率和经济效益。以往对番茄智能收获的研究往往只以…

Python音频分析与线性回归:探索声音中的数学之美

摘要&#xff1a;通过Python实现WAV音频信号处理与线性回归建模&#xff0c;揭示双声道音频的数学关联性&#xff0c;为声音特征分析提供新视角。1. 音频数据处理流程 1.1 WAV文件读取与预处理 使用scipy.io.wavfile读取音频文件&#xff0c;获取采样率与时域信号数据&#xff…

Linux shell脚本数值计算与条件执行

变量的数值计算实践 1 算术运算符 如果要执行算术运算&#xff0c;就会离不开各种运算符号&#xff0c;和其他编程语言类似&#xff0c;Shell 也有很多算术运算符。 下面就给大家介绍一下常见的 Shell 算术运算符&#xff1a; 、-&#xff0c;一元正号和负号。、-&#xff0c;加…

C#实战:基于iTextSharp实现PDF加密小工具

目录 1、技术框架 2、代码实战 2.1 创建窗体 2.2 后台代码逻辑 2.3 PDF加密用户类型 2.4 PDF加密权限列表 3、运行效果 4、总结 大家日常办公中有时候为了文档资料的安全需要对文档进行加密,尤其是针对PDF文档这个场景还是非常广泛的。今天给大家分享使用C#来实现PDF…

基于Labview的旋转机械AI智能诊断系统

1.摘要本文基于 CWRU 公开轴承数据集提出了一套“AI 轻量级模型 LabVIEW 智能诊断系统”。首先&#xff0c;LabVIEW 端构建了可视化、可交互的智能诊断平台。系统能够加载本地振动信号数据&#xff0c;调用训练好的深度学习模型进行故障识别与状态判断。界面集成信号时域监测、…

Qt从qmake迁移到cmake的记录

文章目录1.UI程序[开启/关闭]控制台2.增加宏定义3.在主项目中引入子项目4.使用C语言文件1.UI程序[开启/关闭]控制台 qmake&#xff1a; CONFIG console DEFINES QT_MESSAGELOGCONTEXTcmake&#xff1a; set(CMAKE_WIN32_EXECUTABLE OFF) # ON为关闭控制台 OFF为开启控制台2…

LangChain4J-(3)-模型参数配置

LangChain4j 提供了灵活的模型参数配置方式&#xff0c;允许你根据不同的 AI 模型&#xff08;如 OpenAI、GPT-4、Anthropic 等&#xff09;设置各种参数来控制生成结果。后面手撸代码继续在之前章节的代码上拓展一、日志配置&#xff08;Logging&#xff09;在 LangChain4j 中…

LangGraph - API多种访问方式

本文介绍了Langgraph服务的四种调用方式&#xff1a;1. 通过LangGraph Studio UI界面手动测试&#xff1b;2. 使用Python SDK进行同步/异步调用&#xff1b;3. 通过REST API测试&#xff1b;4. 使用JavaScript SDK接入。Langgraph 服务端代码 graph.pyfrom langchain_openai im…

HEI-612 HART/EtherNet/IPModbus TCP 网关:打通工业通信壁垒

在工业自动化领域&#xff0c;HART 协议设备的广泛应用与以太网网络的高效管理常面临 “协议孤岛” 难题 —— 老旧 HART 传感器、变送器难以接入 EtherNet/IP 或 Modbus TCP 系统&#xff0c;数据双向交互卡顿、调试复杂、兼容性差等问题&#xff0c;严重制约生产效率提升。上…

OSPF 的工作过程、Router ID 机制、报文结构

视频版讲解>>>>>>>>>>>>>>路由协议深度解析&#xff1a;从静态路由到 OSPF 实战 一、回顾静态路由&#xff1a;拓扑与核心逻辑 我们先回到上周讲解的拓扑图&#xff0c;这张图是理解静态路由的核心载体 —— 路由器作为网段分割的…

Qt 6 与 Qt 5 存在的兼容性差异

之前有提到。我的是Qt5&#xff0c;我朋友的是Qt 6&#xff0c;由于版本不兼容问题&#xff0c;在迁移时会有问题。所以这一我们说说这两个的区别。&#xff08; 正文开始喽&#xff01; 总结来说&#xff1a;Qt5迁移至 Qt 6 需&#xff1a;1. 破坏性变更&#xff08;必须修改…

本地windows电脑部署html网页到互联网:html+node.js+ngrok/natapp

目录 核心概念&#xff1a;为什么不能直接分享HTML文件&#xff1f; 1&#xff0c;html文件修改 2&#xff0c;安装设置node.js 3&#xff0c;路由器虚拟服务器 4&#xff0c;采用ngrok工具进行内网穿透&#xff08;国外工具&#xff09; 5&#xff0c;采用natapp工具进行…

electron离线开发核心环境变量npm_config_cache

npm_config_cache 这个环境变量。它在离线环境配置中扮演着核心角色。什么是 npm_config_cache&#xff1f;npm_config_cache 是一个环境变量&#xff0c;用于直接设置 npm 的缓存目录的绝对路径。npm 在安装包时&#xff0c;会遵循一个特定的工作流程&#xff1a;检查缓存&…

CTFshow系列——命令执行web57-60

本篇文章介绍命令执行的另一种情况&#xff0c;CTFshow的Web57-60关的讲解解析&#xff1b;要想了解其它关卡可查看我以往的文章&#xff0c;感谢关注。 文章目录Web57&#xff08;新方法&#xff09;Web58&#xff08;POST型&#xff09;不可用函数可用函数Web59第二种方法&am…

域名、ip、DSN、URL

目录 1、ip 2、域名 3、DSN 4、URL 1、ip 每个连接到Internet上的主机都会分配一个IP地址&#xff0c;此ip是该计算机在互联网上的逻辑地址的唯一标识&#xff0c;计算机之间的访问就是通过IP地址来进行的。写法&#xff1a;十进制的形式&#xff0c;用“.”分开&#xff0…

【JAVA实现websocket】

JAVA实现websocket背景依赖问题代码实现测试背景 近期项目中需要用到websocket&#xff0c;实现即时通信。 依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></depen…