当前位置: 首页 > news >正文

5、在共享内存无指针编程:句柄HANDLE转换为指针

初级代码游戏的专栏介绍与文章目录-CSDN博客

我的github:codetoys,所有代码都将会位于ctfc库中。已经放入库中我会指出在库中的位置。

这些代码大部分以Linux为目标但部分代码是纯C++的,可以在任何平台上使用。


        共享内存里面不能用指针,只能用索引,在windows上经常称之为句柄(当然实际上句柄也并非索引,而是个抽象ID),我在这个系统里使用HANDLE这个名字(因为我是windows出身)。

        但是我们真的要无指针编程吗?那还要什么++?

目录

一、索引如何转换为指针

二、句柄结构

三、代码解读


一、索引如何转换为指针

        没有指针当然是很困难的,不过我们是C++啊,我们可以把索引包装得跟指针差不多。

        但是索引只有一个整数偏移量,而转为指针必须知道起始地址,怎么传递起始地址?增加参数还能当指针使用吗?这要怎么搞呢?

        但是我们是共享内存呀!共享内存是公共资源,不可能随意创建,系统内的共享内存都是被管理的,我们只需要给每个共享内存一个唯一的名字,用全局变量保存其起始地址,那么就可以把索引转换为指针而不需要额外的参数了。(这算是一个花招吧)

        前面介绍共享内存管理接口的时候,提到了共享内存的名字,除了名字,还有一个PI(指针索引),每个共享内存块都有预定义的唯一的名字和索引,另外有一个全局数组存储共享内存入口地址。

二、句柄结构

	template<typename T, int PI_N >struct T_HANDLE_ARRAY{T_SHM_SIZE handle;T_HANDLE_ARRAY(T_SHM_SIZE h = -1) :handle(h) {}T_HANDLE_ARRAY(T_HANDLE_ARRAY const& tmp) :handle(tmp.handle) {}typedef random_access_iterator_tag iterator_category;typedef T* pointer;typedef T element_type;typedef T value_type;typedef long difference_type;typedef long offset_type;typedef T& reference;bool operator<(T_HANDLE_ARRAY const& tmp)const { return handle < tmp.handle; }T_HANDLE_ARRAY operator + (long n)const{T_HANDLE_ARRAY tmp;tmp.handle = handle + n;return tmp;}T_HANDLE_ARRAY operator - (long n)const{T_HANDLE_ARRAY tmp;tmp.handle = handle - n;return tmp;}T_SHM_SIZE operator - (T_HANDLE_ARRAY const& tmp)const { return handle - tmp.handle; }T_HANDLE_ARRAY& operator += (T_SHM_SIZE n) { handle += n; return *this; }T_HANDLE_ARRAY& operator ++ () { ++handle; return *this; }T_HANDLE_ARRAY& operator -- () { --handle; return *this; }T_HANDLE_ARRAY& operator = (T_HANDLE_ARRAY const& tmp) { handle = tmp.handle; return *this; }bool operator == (T_HANDLE_ARRAY const& tmp)const { return handle == tmp.handle; }bool operator != (T_HANDLE_ARRAY const& tmp)const { return !((*this) == tmp); }T& operator * ()const{return *operator ->();}T* operator -> ()const{if (0 == PI_N)throw "SHM PI_N=0";struct_T_ARRAY_VMAP_S* pvmap = (struct_T_ARRAY_VMAP_S*)GET_PP_VMAP(PI_N);shm_private_data* paddrmap = &GET_SHM_PRIVATE_DATA(PI_N);for (long i = 0; i < pvmap->size; ++i){if (pvmap->m_vmaps[i].handle_begin <= handle && handle < pvmap->m_vmaps[i].handle_end){if (pvmap->size > paddrmap->addr_map_size){if (0 != paddrmap->thread_mutex.lock())throw "paddrmap->thread_mutex.lock error";if (pvmap->size > paddrmap->addr_map_size){for (long j = paddrmap->addr_map_size; j < pvmap->size; ++j){char* p = CShmMan::ConnectByID(pvmap->m_vmaps[j].shm_id, false);if (NULL == p){thelog << "连接共享内存失败 shmid = " << pvmap->m_vmaps[j].shm_id << " 错误信息:" << strerror(errno) << ende;throw "连接共享内存失败";}if (((unsigned long)p) % 8 != 0){thelog << "地址对齐错误" << ende;throw "地址对齐错误";}char buf[256];sprintf(buf, "连接共享内存 %d %ld shm_id %d addr %p", PI_N, j, pvmap->m_vmaps[j].shm_id, p);thelog << buf << endi;paddrmap->AddShmMap(pvmap->m_vmaps[j].shm_id, p);}}else{thelog << "已经被其它线程处理" << endi;}if (0 != paddrmap->thread_mutex.unlock())throw "paddrmap->thread_mutex.unlock error";}return (T*)paddrmap->shm_addr_map[i].second + handle - pvmap->m_vmaps[i].handle_begin;}if (i == pvmap->size - 1 && handle == pvmap->m_vmaps[i].handle_end){thelog << "刚好越过最后一个 " << handle << " " << (T*)paddrmap->shm_addr_map[i].second + handle - pvmap->m_vmaps[i].handle_begin << endi;//return (T *)paddrmap->shm_addr_map[i].second+handle-pvmap->m_vmaps[i].handle_begin;}}char buf[2048];sprintf(buf, "->无效的句柄 PI_N=%d handle=%ld", PI_N, handle);theLog << "shmArray.h T_HANDLE_ARRAY" << buf << ende;ShowVMapPrivateData();abort();return NULL;}static T_SHM_SIZE _me(T const* p, bool not_throw = false){char buf[256];struct_T_ARRAY_VMAP_S* pvmap = (struct_T_ARRAY_VMAP_S*)GET_PP_VMAP(PI_N);shm_private_data* paddrmap = &GET_SHM_PRIVATE_DATA(PI_N);for (long i = 0; i < pvmap->size; ++i){if ((T*)paddrmap->shm_addr_map[i].second <= p && p < (T*)paddrmap->shm_addr_map[i].second + pvmap->m_vmaps[i].handle_end - pvmap->m_vmaps[i].handle_begin){return p - (T*)paddrmap->shm_addr_map[i].second + pvmap->m_vmaps[i].handle_begin;}if (i == pvmap->size - 1 && p == (T*)paddrmap->shm_addr_map[i].second + pvmap->m_vmaps[i].handle_end - pvmap->m_vmaps[i].handle_begin){thelog << "刚好越过最后一个 " << p << " " << p - (T*)paddrmap->shm_addr_map[i].second + pvmap->m_vmaps[i].handle_begin << endi;//return p-(T *)paddrmap->shm_addr_map[i].second+pvmap->m_vmaps[i].handle_begin;}}if (not_throw)return -1;else{sprintf(buf, "_me无效的地址 %p", p);throw buf;}}static void ShowVMapPrivateData(){struct_T_ARRAY_VMAP_S* pvmap = (struct_T_ARRAY_VMAP_S*)GET_PP_VMAP(PI_N);shm_private_data* paddrmap = &GET_SHM_PRIVATE_DATA(PI_N);long i, j;theLog << endl;theLog << "pvmap->size=" << pvmap->size << endl;for (i = 0; i < pvmap->size; ++i){theLog << i << " : begin=" << pvmap->m_vmaps[i].handle_begin << " end=" << pvmap->m_vmaps[i].handle_end << endl;}theLog << "paddrmap->addr_map_size=" << paddrmap->addr_map_size << endl;for (j = 0; j < paddrmap->addr_map_size; ++j){theLog << j << " : " << paddrmap->shm_addr_map[j].first << " - " << (long)paddrmap->shm_addr_map[j].second << endl;}theLog << endi;}};

三、代码解读

        这个代码是个模板,参数是指向的类型和入口指针的索引。

        主要部分是自定义的指针类,符合随机迭代器概念要求,可以用在STL算法里。

        复杂的代码部分是在没有连接是自动去连接。由于每个共享内存结构其实是可扩展的,是多个共享内存的串联,因此代码比较复杂。数据的索引是连续的,但不同分块的连接地址并不相同,因此需要一个分块映射表。还要考虑多线程保护。如果没有分块问题,操作会简单很多,只需要根据PI_N获取入口地址,判断是否需要连接,然后就能转换为指针了。


(这里是文档结束)

相关文章:

5、在共享内存无指针编程:句柄HANDLE转换为指针

初级代码游戏的专栏介绍与文章目录-CSDN博客 我的github&#xff1a;codetoys&#xff0c;所有代码都将会位于ctfc库中。已经放入库中我会指出在库中的位置。 这些代码大部分以Linux为目标但部分代码是纯C的&#xff0c;可以在任何平台上使用。 共享内存里面不能用指针&#…...

hive动态分区导致xceivercount超限,hdfs无法创建新连接

目录 一、事件复盘&#xff1a; 二、解决方案&#xff1a; 三、讨论 一、事件复盘&#xff1a; hdfs无法创建新的文件&#xff0c;xceivercount超过最大设置&#xff0c;平时每个datanode只有100个左右的连接&#xff0c;突然达到8000以上。 事故原因&#xff0c;跨多天的…...

如何识别Android init 中的缓慢操作

Android 14 开机时间优化措施汇总-CSDN博客 Android 14 开机时间优化措施-CSDN博客根据systrace报告优化系统时需要关注的指标和优化策略-CSDN博客Android系统上常见的性能优化工具-CSDN博客Android上如何使用perfetto分析systrace-CSDN博客Android系统设置kernel log level的…...

JVM:常用工具总结

文章目录 一、jstat工具 一、jstat工具 Jstat工具是JDK自带的一款监控工具&#xff0c;可以提供各种垃圾回收、类加载、编译信息等不同的数据。使用方法为&#xff1a;jstat -gc进程ID每次统计的时间间隔&#xff08;毫秒&#xff09;统计次数。 C代表Capacity容量&#xff0c…...

二染色,CF 1594D - The Number of Imposters

目录 一、题目 1、题目描述 2、输入输出 2.1输入 2.2输出 3、原题链接 二、解题报告 1、思路分析 2、复杂度 3、代码详解 一、题目 1、题目描述 2、输入输出 2.1输入 2.2输出 3、原题链接 1594D - The Number of Imposters 二、解题报告 1、思路分析 并查集&…...

Go语言并发编程-Channel通信_2

Channel通信 Channel概述 不要通过共享内存的方式进行通信&#xff0c;而是应该通过通信的方式共享内存 这是Go语言最核心的设计模式之一。 在很多主流的编程语言中&#xff0c;多个线程传递数据的方式一般都是共享内存&#xff0c;而Go语言中多Goroutine通信的主要方案是Cha…...

Richteck立锜科技电源管理芯片简介及器件选择指南

一、电源管理简介 电源管理组件的选择和应用本身的电源输入和输出条件是高度关联的。 输入电源是交流或直流&#xff1f;需求的输出电压比输入电压高或是低&#xff1f;负载电流多大&#xff1f;系统是否对噪讯非常敏感&#xff1f;也许系统需要的是恒流而不是稳压 (例如 LED…...

Socket 简介与 Java Socket 编程示例

Socket&#xff08;套接字&#xff09;是网络通信中的一个关键概念&#xff0c;它是对网络中不同主机上的应用进程之间进行双向通信的端点的抽象。 一、定义与概念 基本概念&#xff1a;Socket可以被视为网络环境中进程间通信的API&#xff08;应用程序编程接口&#xff09;&…...

跟着操作,解决iPhone怎么清理内存难题

在如今智能手机功能日益强大的时代&#xff0c;我们使用手机拍照、录制视频、下载应用、存储文件等操作都会占用手机内存。当内存空间不足时&#xff0c;手机运行会变得缓慢&#xff0c;甚至出现卡顿、闪退等现象。因此&#xff0c;定期清理iPhone内存是非常必要的。那么&#…...

React、Vue的password输入框组件,如何关闭自动填充?

有时候我们的表单使用了一个password组件&#xff0c;这时候每次打开新建&#xff0c;都会自动获取浏览器缓存的密码&#xff0c;但是它的上一个input输入框并不是用户名&#xff0c;这时候我们希望我们的表单&#xff0c;每次点开的时候密码是空的&#xff0c;让用户自动输入&…...

HTML+JS+CSS计算练习

可填 题目数量 数字范围 计算符号 题目做完后会弹窗提示正确率、用时 效果图 源代码在图片后面 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevic…...

设计模式使用场景实现示例及优缺点(行为型模式——责任链模式)

在一个遥远的森林深处&#xff0c;有一个和谐的动物王国。这个王国里的动物们都有各自的职责&#xff0c;大家相互合作&#xff0c;共同维护着森林的和平与繁荣。 一天&#xff0c;森林里来了一只迷路的小兔子&#xff0c;她焦急地四处张望&#xff0c;不知道该怎么办。于是&am…...

CSS-1_0 CSS和文档流

文章目录 CSS和文档流如何证明这个流的存在呢&#xff1f;流和display番外&#xff1a;inline-block 碎碎念 CSS和文档流 首先什么叫流呢&#xff1f; 通常来说&#xff0c;我们最终看到的网页是HTML文档中定义的各个元素挨个输出的结果&#xff0c;这种一个接一个输出的方式…...

小程序图片下载保存方法,图片源文件保存!

引言 现在很多时候我们在观看到小程序中的图片的时候&#xff0c;想保存图片的原文件格式的话&#xff0c;很多小程序是禁止保存的&#xff0c;即使是让保存的话&#xff0c;很多小程序也会限制不让保存原文件&#xff0c;只让保存一些分辨率很低的&#xff0c;非常模糊的图片…...

新书速览|深入理解Hive:从基础到高阶:视频教学版

《深入理解Hive&#xff1a;从基础到高阶&#xff1a;视频教学版》 本书内容 《深入理解Hive:从基础到高阶:视频教学版》采用“理论实战”的形式编写&#xff0c;通过大量的实例&#xff0c;结合作者多年一线开发实战经验&#xff0c;全面地介绍Hive的使用方法。《深入理解Hiv…...

钡铼Profinet、EtherCAT、Modbus、MQTT、Ethernet/IP、OPC UA分布式IO系统BL20X系列耦合器

BL20X系列耦合器是钡铼技术开发的一款用于分布式I/O系统的设备&#xff0c;专为工业环境下的高速数据传输和远程设备控制而设计&#xff0c;支持多种工业以太网协议&#xff0c;包括Profinet、EtherCAT、Modbus、MQTT、Ethernet/IP和OPC UA等。如果您正在考虑部署BL20X系列耦合…...

Git分支合并以及分支部分合并 提交记录合并

Git分支合并,以及分支部分合并,提交记录合并 最近工作中用到git分支合并的场景,记录一下. 分支整体合并,合并所有记录 仅合并分支部分代码...

IDEA关联数据库

《IDEA破解、配置、使用技巧与实战教程》系列文章目录 第一章 IDEA破解与HelloWorld的实战编写 第二章 IDEA的详细设置 第三章 IDEA的工程与模块管理 第四章 IDEA的常见代码模板的使用 第五章 IDEA中常用的快捷键 第六章 IDEA的断点调试&#xff08;Debug&#xff09; 第七章 …...

【Leetcode】14. 最长公共前缀

leetcode原地址&#xff1a;https://leetcode.cn/problems/longest-common-prefix 描述 编写一个函数来查找字符串数组中的最长公共前缀。 如果不存在公共前缀&#xff0c;返回空字符串 “”。 示例 1&#xff1a; 输入&#xff1a;strs [“flower”,“flow”,“flight”…...

【BUG】已解决:zipfile.BadZipFile: File is not a zip file

已解决&#xff1a;zipfile.BadZipFile: File is not a zip file 欢迎来到英杰社区https://bbs.csdn.net/topics/617804998 欢迎来到我的主页&#xff0c;我是博主英杰&#xff0c;211科班出身&#xff0c;就职于医疗科技公司&#xff0c;热衷分享知识&#xff0c;武汉城市开发…...

CMake基础:构建流程详解

目录 1.CMake构建过程的基本流程 2.CMake构建的具体步骤 2.1.创建构建目录 2.2.使用 CMake 生成构建文件 2.3.编译和构建 2.4.清理构建文件 2.5.重新配置和构建 3.跨平台构建示例 4.工具链与交叉编译 5.CMake构建后的项目结构解析 5.1.CMake构建后的目录结构 5.2.构…...

定时器任务——若依源码分析

分析util包下面的工具类schedule utils&#xff1a; ScheduleUtils 是若依中用于与 Quartz 框架交互的工具类&#xff0c;封装了定时任务的 创建、更新、暂停、删除等核心逻辑。 createScheduleJob createScheduleJob 用于将任务注册到 Quartz&#xff0c;先构建任务的 JobD…...

srs linux

下载编译运行 git clone https:///ossrs/srs.git ./configure --h265on make 编译完成后即可启动SRS # 启动 ./objs/srs -c conf/srs.conf # 查看日志 tail -n 30 -f ./objs/srs.log 开放端口 默认RTMP接收推流端口是1935&#xff0c;SRS管理页面端口是8080&#xff0c;可…...

ffmpeg(四):滤镜命令

FFmpeg 的滤镜命令是用于音视频处理中的强大工具&#xff0c;可以完成剪裁、缩放、加水印、调色、合成、旋转、模糊、叠加字幕等复杂的操作。其核心语法格式一般如下&#xff1a; ffmpeg -i input.mp4 -vf "滤镜参数" output.mp4或者带音频滤镜&#xff1a; ffmpeg…...

分布式增量爬虫实现方案

之前我们在讨论的是分布式爬虫如何实现增量爬取。增量爬虫的目标是只爬取新产生或发生变化的页面&#xff0c;避免重复抓取&#xff0c;以节省资源和时间。 在分布式环境下&#xff0c;增量爬虫的实现需要考虑多个爬虫节点之间的协调和去重。 另一种思路&#xff1a;将增量判…...

微软PowerBI考试 PL300-在 Power BI 中清理、转换和加载数据

微软PowerBI考试 PL300-在 Power BI 中清理、转换和加载数据 Power Query 具有大量专门帮助您清理和准备数据以供分析的功能。 您将了解如何简化复杂模型、更改数据类型、重命名对象和透视数据。 您还将了解如何分析列&#xff0c;以便知晓哪些列包含有价值的数据&#xff0c;…...

C# 表达式和运算符(求值顺序)

求值顺序 表达式可以由许多嵌套的子表达式构成。子表达式的求值顺序可以使表达式的最终值发生 变化。 例如&#xff0c;已知表达式3*52&#xff0c;依照子表达式的求值顺序&#xff0c;有两种可能的结果&#xff0c;如图9-3所示。 如果乘法先执行&#xff0c;结果是17。如果5…...

MySQL 索引底层结构揭秘:B-Tree 与 B+Tree 的区别与应用

文章目录 一、背景知识&#xff1a;什么是 B-Tree 和 BTree&#xff1f; B-Tree&#xff08;平衡多路查找树&#xff09; BTree&#xff08;B-Tree 的变种&#xff09; 二、结构对比&#xff1a;一张图看懂 三、为什么 MySQL InnoDB 选择 BTree&#xff1f; 1. 范围查询更快 2…...

书籍“之“字形打印矩阵(8)0609

题目 给定一个矩阵matrix&#xff0c;按照"之"字形的方式打印这个矩阵&#xff0c;例如&#xff1a; 1 2 3 4 5 6 7 8 9 10 11 12 ”之“字形打印的结果为&#xff1a;1&#xff0c;…...

ArcPy扩展模块的使用(3)

管理工程项目 arcpy.mp模块允许用户管理布局、地图、报表、文件夹连接、视图等工程项目。例如&#xff0c;可以更新、修复或替换图层数据源&#xff0c;修改图层的符号系统&#xff0c;甚至自动在线执行共享要托管在组织中的工程项。 以下代码展示了如何更新图层的数据源&…...