7.高并发内存池大页内存申请释放以及使用定长内存池脱离new

在高并发内存池的设计中,“大页内存管理” 和 “元数据开销优化” 是两个核心痛点:原生malloc/free在大内存分配时频繁触发系统调用,而new/delete管理内存池元对象(如ThreadCachespan)会引入额外性能损耗。本文基于 TCMalloc 思想,拆解高并发内存池中大页内存的申请 / 释放逻辑,以及如何通过定长内存池(ObjectPool) 彻底脱离new/delete,实现元数据的零开销管理

一、背景:为什么要单独处理大页内存?

在高并发内存池的三级缓存架构(ThreadCache→CentralCache→PageCache)中,我们将内存分为 “小对象(≤256KB)” 和 “大对象(>256KB)”:

  • 小对象:走三级缓存,利用线程私有、桶锁、批量分配降低竞争
  • 大对象:若仍走缓存,会导致 “缓存污染”(大内存占满缓存,小对象无空间可用),且大内存分配频率低,缓存收益有限

因此,大对象直接走PageCache申请连续物理页(大页),跳过ThreadCacheCentralCache,核心目标是:

  1. 减少系统调用次数(批量申请连续页,而非单次小内存)
  2. 避免大内存碎片化(用span管理连续页块,空闲后自动合并)
  3. 保证高并发下的线程安全(全局页锁 + 细粒度控制)

二、核心 1:大页内存的申请与释放实现

2.1 大页内存的定义与申请策略

(1)大页判定规则

我们定义 “大对象” 为超过 256KB 的内存(可根据场景调整),对应物理页数量为:

// Common.h 核心宏定义 #define MAX_BYTES (256 * 1024) // 小对象上限 #define PAGE_SIZE 8192 // 单页8KB #define PAGE_SHIFT 13 // 2^13=8192,用于页ID与地址转换 #define MAX_PAGE_BUCKETS 128 // 最大连续页数量(128*8KB=1024KB) typedef size_t PAGE_ID; // 页ID类型 

当申请内存size > MAX_BYTES时,判定为大对象,直接走PageCache申请连续页(大页),而非三级缓存

(2)大页内存申请核心逻辑

大页申请的核心是 “以页为单位分配连续物理页”,避免原生malloc的碎片化问题,核心代码如下:

// ConcurrentAlloc.h - 用户层大对象申请接口 void* ConcurrentAlloc(size_t size) { if (size > MAX_BYTES) { // 1. 内存对齐:大对象对齐到页大小,避免跨页浪费 size_t alignSize = SizeClass::RoundUp(size); // 2. 计算需要的连续页数 size_t kPages = alignSize >> PAGE_SHIFT; // 3. 加全局页锁,保证线程安全 PageCache::GetInstance()->_pageMutex.lock(); // 4. 向PageCache申请连续kPages页的span(大页) span* bigSpan = PageCache::GetInstance()->NewSpan(kPages); PageCache::GetInstance()->_pageMutex.unlock(); // 5. 页ID转换为内存地址(核心:页ID * 页大小 = 起始地址) uintptr_t addr = (uintptr_t)bigSpan->_pageId * PAGE_SIZE; return (void*)addr; } // 小对象走ThreadCache... } 
(3)PageCache::NewSpan 大页申请核心

NewSpan是大页申请的核心,逻辑为 “先查空闲 span→无则向系统申请连续页”:

// PageCache.cpp span* PageCache::NewSpan(size_t kPages) { // 1. 优先从对应页数的空闲span链表中取 if (!_spanlist[kPages].Empty()) { span* span = _spanlist[kPages].Pop_front(); // 初始化页ID到span的映射(仅首尾页,高效) _idSpanMap[span->_pageId] = span; _idSpanMap[span->_pageId + span->_n - 1] = span; span->_isUse = true; return span; } // 2. 无空闲span,向更大页数的span链表找(拆分) for (size_t i = kPages + 1; i < MAX_PAGE_BUCKETS; ++i) { if (!_spanlist[i].Empty()) { span* bigSpan = _spanlist[i].Pop_front(); // 拆分出kPages页的span span* newSpan = new span; newSpan->_pageId = bigSpan->_pageId; newSpan->_n = kPages; newSpan->_isUse = true; // 剩余页放回PageCache bigSpan->_pageId += kPages; bigSpan->_n -= kPages; _spanlist[bigSpan->_n].Push_front(bigSpan); // 更新映射 _idSpanMap[newSpan->_pageId] = newSpan; _idSpanMap[newSpan->_pageId + newSpan->_n - 1] = newSpan; _idSpanMap[bigSpan->_pageId] = bigSpan; _idSpanMap[bigSpan->_pageId + bigSpan->_n - 1] = bigSpan; return newSpan; } } // 3. 无任何空闲span,向系统申请128页(大页) size_t allocPages = MAX_PAGE_BUCKETS - 1; void* ptr = SystemAlloc(allocPages); // 封装VirtualAlloc/mmap span* newSpan = new span; newSpan->_pageId = (PAGE_ID)ptr >> PAGE_SHIFT; // 地址转页ID newSpan->_n = allocPages; _spanlist[allocPages].Push_front(newSpan); // 递归拆分(仅1层,无栈溢出风险) return NewSpan(kPages); } 

2.2 大页内存的释放逻辑

大页释放的核心是 “归还 span 到 PageCache + 双向合并空闲 span”,避免内存碎片化,核心代码:

// ConcurrentAlloc.h - 用户层大对象释放接口 void ConcurrentFree(void* ptr, size_t size) { assert(ptr); if (size > MAX_BYTES) { // 1. 通过地址反查对应的span(核心:_idSpanMap映射) PageCache::GetInstance()->_pageMutex.lock(); span* bigSpan = PageCache::GetInstance()->MapObjectToSpan(ptr); // 2. 归还span到PageCache并合并 PageCache::GetInstance()->ReleaseSpanToPageCache(bigSpan); PageCache::GetInstance()->_pageMutex.unlock(); return; } // 小对象走ThreadCache... } // PageCache.cpp - span合并核心 void PageCache::ReleaseSpanToPageCache(span* obj) { // 1. 前向合并:合并前一页的空闲span while (true) { PAGE_ID prevId = obj->_pageId - 1; auto it = _idSpanMap.find(prevId); if (it == _idSpanMap.end()) break; span* prevSpan = it->second; if (prevSpan->_isUse || prevSpan->_n + obj->_n > MAX_PAGE_BUCKETS - 1) break; // 合并prevSpan到当前span _spanlist[prevSpan->_n].Erase(prevSpan); obj->_pageId = prevSpan->_pageId; obj->_n += prevSpan->_n; delete prevSpan; // 此处后续用定长内存池优化 } // 2. 后向合并:合并后一页的空闲span(逻辑同上) while (true) { PAGE_ID nextId = obj->_pageId + obj->_n; auto it = _idSpanMap.find(nextId); if (it == _idSpanMap.end()) break; span* nextSpan = it->second; if (nextSpan->_isUse || nextSpan->_n + obj->_n > MAX_PAGE_BUCKETS - 1) break; _spanlist[nextSpan->_n].Erase(nextSpan); obj->_n += nextSpan->_n; delete nextSpan; // 此处后续用定长内存池优化 } // 3. 标记为空闲,更新首尾页映射(高效设计) obj->_isUse = false; _spanlist[obj->_n].Push_front(obj); _idSpanMap[obj->_pageId] = obj; _idSpanMap[obj->_pageId + obj->_n - 1] = obj; } 

2.3 大页内存管理的核心优势

  1. 低碎片化:连续页块通过 span 合并,避免原生 malloc 的 “内存洞”;
  2. 少系统调用:向系统一次申请 128 页,拆分后复用,大幅减少 VirtualAlloc/mmap 调用;
  3. 高并发安全:全局页锁仅在申请 / 释放大页时持有,持有时间极短,不影响小对象并发;
  4. 地址映射高效:仅维护 span 首尾页的映射,而非全量页,哈希表开销降低 90%+。

三、核心 2:定长内存池(ObjectPool)脱离 new/delete

上述代码中,new spandelete span会引入额外开销:new需要调用构造函数 + 内存分配,delete需要调用析构函数 + 内存释放,而span作为内存池的元对象,创建 / 销毁频率极高,必须优化,而且最重要的是,我们写的这个不就是要替换malloc和new吗,要是代码中还使用的话,不就相当于左脚踩右脚了吗!!!

3.1 定长内存池的设计思路

定长内存池(ObjectPool)的核心是 “预分配一块连续内存,按固定大小切割,管理空闲链表”,适用于:

  • 频繁创建 / 销毁的定长对象(如 span、ThreadCache)
  • 避免 new/delete 的系统调用和锁竞争
  • 支持定位 new 和显式析构,兼容 C++ 对象生命周期

3.2 ObjectPool 核心实现

// Fixed-size_memory_pool.h template<class T> class ObjectPool { public: // 申请对象(脱离new) T* New() { T* obj = nullptr; // 1. 优先从空闲链表取 if (_freeList) { obj = (T*)_freeList; _freeList = *((void**)_freeList); // 头删 } else { // 2. 空闲链表空,向系统申请大块内存 if (_leftBytes < sizeof(T)) { _leftBytes = 128 * 1024; // 预分配128KB // 按页申请,避免内存碎片 size_t pageNum = _leftBytes / PAGE_SIZE; _memory = (char*)SystemAlloc(pageNum); if (_memory == nullptr) throw std::bad_alloc(); } // 切割内存块 obj = (T*)_memory; size_t objSize = sizeof(T) < sizeof(void*) ? sizeof(void*) : sizeof(T); _memory += objSize; _leftBytes -= objSize; } // 3. 定位new:仅初始化对象,不分配内存(核心) new(obj)T(); return obj; } // 释放对象(脱离delete) void Delete(T* obj) { // 1. 显式析构:仅清理对象,不释放内存 obj->~T(); // 2. 头插到空闲链表 size_t objSize = sizeof(T) < sizeof(void*) ? sizeof(void*) : sizeof(T); *((void**)obj) = _freeList; _freeList = obj; } private: char* _memory = nullptr; // 预分配的连续内存块 int _leftBytes = 0; // 剩余可用字节数 void* _freeList = nullptr; // 空闲对象链表 }; 

3.3 替换 new/delete:以 span 和 ThreadCache 为例

(1)管理 span 对象

PageCache中所有new span/delete span替换为 ObjectPool:

// PageCache.h class PageCache { private: ObjectPool<span> _spanPool; // 定长内存池管理span public: span* NewSpan(size_t kPages) { // 替换new span span* newSpan = _spanPool.New(); // ... 其他逻辑 } void ReleaseSpanToPageCache(span* obj) { // ... 合并逻辑 // 替换delete span _spanPool.Delete(prevSpan); _spanPool.Delete(nextSpan); } }; 
(2)管理 ThreadCache 对象

ThreadCache 是线程私有对象,创建频率高,用 ObjectPool 管理:

// ConcurrentAlloc.h static __thread ThreadCache* pTLSThreadCache = nullptr; void* ConcurrentAlloc(size_t size) { if (size <= MAX_BYTES) { if (pTLSThreadCache == nullptr) { // 替换new ThreadCache static ObjectPool<ThreadCache> tcPool; pTLSThreadCache = tcPool.New(); } return pTLSThreadCache->Allocate(size); } // ... 大对象逻辑 } 

3.4 定长内存池的核心收益

  1. 零开销创建 / 销毁:空闲对象直接从链表取,无需系统调用,速度比 new
  2. 内存连续:预分配的大块内存减少 TLB 缺失,访问效率更高
  3. 对象生命周期可控:定位 new + 显式析构,既兼容 C++ 对象,又脱离 new/delete 的束缚;
  4. 无锁(线程私有):每个 ThreadCache 的 ObjectPool 是线程私有,无并发竞争

四、整体性能对比

场景原生 malloc/free + new/delete高并发内存池(大页 + 定长池)
大对象分配耗时高(频繁系统调用)低(批量申请 + span 复用)
元对象创建耗时高(new/delete 锁竞争)极低(空闲链表无锁)
内存碎片率高(零散分配)低(span 合并 + 定长切割)
多线程并发吞吐量低(全局锁竞争)高(桶锁 + 线程私有)

五、总结

高并发内存池的性能优化,本质是 “场景适配 + 开销极致压缩”:

  1. 大页内存管理:通过 span 抽象连续页块,批量申请、双向合并,解决大对象碎片化和系统调用频繁问题
  2. 定长内存池:针对高频创建的元对象,预分配连续内存、管理空闲链表,彻底脱离 new/delete,实现零开销对象管理

这两个设计的结合,让内存池既保证了大内存的高效管理,又解决了元数据的性能损耗,是 TCMalloc 等工业级内存池的核心精髓,也是高并发场景下内存管理的最优解之一

附:核心注意事项

  1. 大页合并时仅维护首尾页映射,兼顾效率和正确
  2. 定长内存池的对象大小需对齐到 void*,避免越界访问
  3. 线程私有 ObjectPool 需配合 TLS 使用,避免并发竞争
  4. 向系统申请的大页内存,需在进程退出时主动释放(封装 SystemFree)

Read more

Elasticsearch + Kibana 实战指南:从安装部署到 C++ 客户端封装,解锁搜索引擎开发核心技能

Elasticsearch + Kibana 实战指南:从安装部署到 C++ 客户端封装,解锁搜索引擎开发核心技能

文章目录 * 本篇摘要 * 一.ES 介绍及简单使用 * 1·介绍 * 2.安装过程 * 检测是否安转成功 * 对应配置文件修改 * 3.ES核心知识概念 * **1. 索引(Index-->库)** * **2. 文档(Document)** * **3. 字段(Field)** * **4. 类型(Type-->类似表)**(7.x后已废弃) * **5. 映射(Mapping)** * 4.kibana介绍 * **Kibana 是什么?** * **Kibana 和 Elasticsearch 的关系** * 5.安装Kibana过程 * 6.kibana-es使用 * 7.es-client使用及封装使用接口 * es接口 * 1.

By Ne0inhk
【C++】哈希扩展——位图和布隆过滤器的介绍与实现

【C++】哈希扩展——位图和布隆过滤器的介绍与实现

各位读者大佬好,我是落羽!一个坚持不断学习进步的学生。 如果您觉得我的文章还不错,欢迎多多互三分享交流,一起学习进步! 也欢迎关注我的blog主页:落羽的落羽 文章目录 * 一、位图 * 1. 概念与实现 * 2. std::bitset * 二、布隆过滤器 * 1. 概念 * 2. 布隆过滤器误判率数学推导 * 3. 实现 一、位图 1. 概念与实现 在许多公司的面试题中会考到这样的场景:给40亿个不重复无符号整数,如何快速判断一个数是否在这40亿数中。 如果使用常规思路,每次查询暴力遍历O(N)太慢,排序+二分查找O(NlogN)+O(logN),内存不足以放下这些数据。 数据是否在给定的整型数据中,结果是在或不在,正好是两种状态,那么可以用一个二进制比特位来代表数据是否存在的信息,比特位为1代表存在,比特位为0代表不在。那么,我们可以设计一个用比特位表示数据是否存在的数据结构——位图!

By Ne0inhk
Java外功实战(4)——SpringBoot登录认证全栈实现:Session、统一结果封装、MD5加密与拦截器

Java外功实战(4)——SpringBoot登录认证全栈实现:Session、统一结果封装、MD5加密与拦截器

本文简介 目的:Spring生态为Java后端开发提供了强大支持,但将分散的技术点整合成完整解决方案往往令人困惑。本文将以登录接口为切入点,系统演示如何将IOC/DI、MyBatis数据持久化、MD5加密、Session/Cookie管理、JWT令牌和拦截器机制融合运用,打造企业级认证方案 技术栈:前端:HTML + CSS + JavaScript + Jquery后端:SpringBoot + Mybatis + JWT 搭建环境:数据库:MySQL8.4.0项目结构:maven前端框架:Jquery后端框架:SpringBootJDK:17编译器:IDEA 目录结构: 项目搭建及配置 1.创建SpringBoot3.0.0+项目并添加依赖:Spring Web、MyBatis Framework、MySQL Driver、Lombok 2.初始化数据库: createdatabase spring_

By Ne0inhk