POXIS共享内存及信号量使用

文章目录

      • POSIX共享内存
        • shm_open
        • ftruncate
        • mmap
        • POXIS共享内存文件的位置
        • munmap
        • close
      • POXIS信号量
        • POXIS信号量的共同操作
          • sem_wait
          • sem_post
          • sem_getvalue
          • sem_t
          • 有名信号量
            • sem_open
            • sem_close
            • sem_unlink
        • 无名信号量
            • sem_init - 初始化信号量
            • sem_destroy - 销毁信号量
        • 多进程注意事项
          • 问题一
          • 问题二
        • 封装
          • **有名信号量的封装**
        • 无名信号量的封装 --对多线程使用的封装
        • POSIX共享内存的封装

关于其原理有许多其他博客讲过,这里不再赘述,主要是编者自己写了一份封装,以及一些使用共享内存需要注意事项。

POSIX共享内存

关键函数:

shm_open

int shm_open(const char *name, int oflag, mode_t mode);
name:是共享内存的名字,因为其实POXIS的共享内存是由文件映射的,这个名字是最好不要和已有共享内存的名字的重复,否则用的就是同一个共享内存了
oflag:类似于打开文件的标志,一般用 O_CREAT | O_TRUNC | O_RDWR |O_EXCL等与文件一样的使用权限符。
* O_CREAT : 创建共享内存,如果已经存在就打开
* O_TRUNC : 打开之后会清空这个文件的意思,这里就是指清空共享内存的内容
* O_EXCL : 一般用于打开时检测是否已经存在了,存在就返回错误。
mode:用来表示你所创建的共享内存的权限。因为前面说过了,这里其实是文件的映射,可以传0666,一样要减去umask

返回值:是一个文件描述符,是搭配后面映射到内存地址空间的。小于0自然就是失败了,这和打开文件一样,需要判断。


oflag参数与open函数的flags一样,必须含有O_RDONLY或O_RDWR标准。


mode参数与open函数的mode一样,是指定权限位。如果没有指定O_CREAT标志,那么该参数可以指定为0。

ftruncate

int ftruncate(int fd, off_t length);
fd: 是已打开文件的文件描述符
length: 是指定的新文件大小。

函数的返回值表示操作的成功或失败。如果成功,返回值为0;如果失败,返回值为-1,并设置相应的错误码来指示错误类型。
一般搭配:mmap使用,一般来说

mmap

void *mmap(void* addr, size_t length, int prot, int flags,
int fd, off_t offset);

  • addr:指定映射区域的起始地址。通常设置为NULL,让系统选择地址。
  • length:映射区域的长度,以字节为单位。通常不超过你上面设置的大小
  • prot:映射区域的保护标志,指定映射区域的内存访问权限,可以是PROT_READ、PROT_WRITE和PROT_EXEC的组合。//EXEC是可执行程序的意思
  • flags:指定映射的类型和其他选项,例如MAP_SHARED或MAP_PRIVATE。
    • MAP_SHARED
      当使用MAP_SHARED标志时,映射区域和原始文件(或其他对象)是共享的。对映射区域的写操作会反映到原始文件中,即写操作会更新文件的内容。同样,如果其他进程修改了共享文件的内容,这些修改也会反映到映射区域中。这种映射方式允许多个进程通过访问相同的映射区域来共享数据。

    • MAP_PRIVATE
      当使用MAP_PRIVATE标志时,映射区域是私有的。对映射区域的写操作不会反映到原始文件中。相反,它们会创建一个映射区域的私有副本,即所谓的写时复制(copy-on-write)行为。这意味着初始时,映射区域和原始文件的内容是共享的,但一旦对映射区域进行写操作,系统会在需要时复制相应的页面,以确保私有映射区域中的修改不会影响原始文件或其他进程对同一文件的映射。

  • fd:文件描述符,通常是由open或shm_open返回的文件描述符,用于指定要映射的文件。
  • offset:从文件开头起算的偏移量,以字节为单位,指定映射区域的起始位置。

返回值:映射在你内存地址空间的并且已经计算过偏移量的地址。

做完上面三步,你就可以直接使用这个共享内存了。

POXIS共享内存文件的位置

如果你向查看你创建的共享内存文件以及信号量,ls /dev/shm

munmap

int munmap(void addr[.length], size_t length);

  • addr:指向要解除映射的内存区域的起始地址的指针。这个地址应该是之前 mmap 调用返回的指针。
  • length:要解除映射的内存区域的长度,以字节为单位。
close

int close(int fd);
不多介绍,之间你创建打开文件,是打开了文件描述符的。
为了防止文件描述符泄露,是需要你关闭的。经过测试你在映mmap之后呢,关闭不影响使用的

POXIS信号量

分为有名信号量与无名信号量

POXIS信号量的共同操作
sem_wait

int sem_wait(sem_t *sem);
取走信号量

  • 除此之外还有 sem_trywait等函数,课自行查阅手册。
sem_post

int sem_post(sem_t *sem);
增加信号量

sem_getvalue

int sem_getvalue(sem_t *sem, int *sval);
查询信号量值

sem_t

信号量类型

有名信号量

推荐多进程不同进程之间使用有名信号量

sem_open

sem_t *sem_open(const char *name, int oflag);
sem_t *sem_open(const char *name, int oflag,mode_t mode, unsigned int value);

  • name是一个标识信号量的字符串。
  • oflag用来确定是创建信号量还是连接已有的信号量。 oflag的参数可以为0,O_CREAT或O_EXCL:如果为0,表示打开一个已存在的信号量;如果为O_CREAT,表示如果信号量不存在就创建一个信号量,如果存在则打开被返* 回,此时mode和value都需要指定;如果为O_CREAT|O_EXCL,表示如果信号量存在则返回错误。
  • mode 用于创建信号量时指定信号量的权限位,和open函数一样,包括:S_IRUSR(用户读)、S_IWUSR(用户写)、S_IRGRP(组读)、S_IWGRP(组写)、S_IROTH、S_IWOTH。//其实和0666的文件权限一个用法,你可以直接传八进制,一样受umask
  • value 表示创建信号量时,信号量的初始值。
sem_close

int sem_close(sem_t *sem);
关闭信号量:如果函数执行成功,则返回0;如果失败,则返回-1。

sem_unlink

int sem_unlink(const char *name);
如果函数成功,则返回 0;如果失败,则返回 -1 并设置 errno 以指示错误原因。
**引用计数:调用 sem_unlink 并不会立即销毁信号量对象。只有在最后一个通过 sem_open 打开该信号量的进程调用 sem_close 后,信号量对象才会被销毁。如果还有其他进程打开了该信号量,则 sem_unlink 只是从文件系统中删除名称,信号量对象仍然存在。

持久性:通过 sem_open 创建的信号量默认是持久的,这意味着即使创建它们的进程已经终止,信号量仍然存在。sem_unlink 用于删除这些持久的信号量。

错误处理:如果尝试删除一个不存在的信号量,sem_unlink 将返回 -1 并设置 errno 为 ENOENT。**

无名信号量

一般只在多线程使用:因为有名信号量在多线程中使用其实更容易操作。
为什么?
因为无名信号量一旦创建,那就算是在父子进程之间,也是各自有一份,这样就导致没法使用同一个信号量。除非你创建在共享内存,那就比较麻烦了。
但是线程的优势就在于共用一块进程地址空间

sem_init - 初始化信号量

int sem_init(sem_t *sem, int pshared, unsigned int value);
sem:指向要初始化的信号量的指针。
pshared:决定信号量的作用域。如果pshared为0,则信号量用于线程间的同步;如果pshared不为0,则信号量用于进程间的同步。
value:信号量的初始值。

sem_destroy - 销毁信号量

int sem_destroy(sem_t *sem);
sem:指向已初始化的信号量的指针

多进程注意事项
问题一

编者在使用多进程时,父进程播种,想用每个子进程进程生成随机数。
但是生成的随机数所有子进程都是一样的,原因是随机数种子两个子进程用的都是同一个。

编者一开始想到这个问题,于是在各自子进程创建之处播种。
但是依然不行。原因是CPU执行速度过于快,可能在你播种之处,c语言的time是秒级别的。会更新不上导致种子一样。

解决办法:srand(time(NULL)%getpid());//模上对应的pid或者和pid做一些运算来独特种子。

问题二

当你在使用多进程对一个文件进行读写的时候。
比如显示器,尤其是你在写的时候,你虽然使用了信号量来保证了读写顺序的问题。
但是是有语言级别的缓冲区的,你在写的时候,仅仅只是写入了语言缓冲区,而这个时候如果你就解除信号量的限制,让其他进程来进行读写。
你这个进程的读写数据就依旧留存在语言缓冲区,也就是进程地址空间的,并没有真正写入文件。
当你有多个进程如此,那么很有可能就会出现一些无法预料的问题。

封装
有名信号量的封装
#include <stdio.h>  
#include <stdlib.h>  
#include <unistd.h>  
#include <sys/sem.h>  
#include <fcntl.h>
#include <semaphore.h>
#include <string>//信号量的封装
class Sem{sem_t* _sem;std::string _pathname;public:Sem( int Soruce_InitNums =0,std::string lpathname = "Sem_Name",int mode =O_CREAT | O_RDWR ,int mod = 0666){_pathname = lpathname;_sem = sem_open(lpathname.c_str(),mode,mod,Soruce_InitNums);}//放入资源void Push(){sem_post(_sem);}//拿走资源void Get(){sem_wait(_sem);}int Val(){int val;sem_getvalue(_sem,&val);return val;}std::string name(){return _pathname;}~Sem(){sem_close(_sem);//最后一个信号量释放时,这样就可以删除,因为如果有信号量的链接,是不会上删除的。if (sem_unlink(_pathname.c_str()) == -1) {  perror("sem_unlink");  }  }//禁用复制重载和拷贝Sem(Sem&) = delete;Sem& operator=(Sem&) = delete;
};
无名信号量的封装 --对多线程使用的封装

#include <pthread.h>
#include <semaphore.h>//信号量的封装
class Sem{sem_t _sem;public://多进程的无名信号量编者就不实现了Sem( int Soruce_InitNums =0,int process_share = 0){sem_init(&_sem,process_share,Soruce_InitNums);}//放入资源void Push(){sem_post(&_sem);}//拿走资源void Get(){sem_wait(&_sem);}~Sem(){sem_destroy(&_sem);}//禁用复制重载和拷贝Sem(Sem&) = delete;Sem& operator=(Sem&) = delete;
};
POSIX共享内存的封装
#include "Common.hpp"
#include <fcntl.h>  
#include <sys/mman.h>  
#include <unistd.h>  
#include <iostream>class ShareMemory{int _shm_fd;char* _shm_ptr;int _size;std::string _pathname;//表示可以挂接bool _attach = 0 ;public:char* Ptr_ToShm(){return _shm_ptr;}//提供默认共享内存的开创和挂接,读写方式处理,认为时可执行ShareMemory(std::string lpathname = pathname,int mode = O_RDWR | O_CREAT,int mod = 0777,int lshmSize =shmSize){_pathname = lpathname;_shm_fd = shm_open(lpathname.c_str(),mode,mod);if(_shm_fd<0){perror(shm_open);exit(errno);}int _size = lshmSize;if (ftruncate(_shm_fd, _size)){perror("ftruncate error");exit(-1);}_shm_ptr = (char*)mmap(NULL,_size,PROT_READ|PROT_WRITE,MAP_SHARED,_shm_fd,0);close(_shm_fd);_attach = 1;if(_shm_ptr==MAP_FAILED){perror("mmap");}   }void change_size(int length){if (ftruncate(_shm_fd, _size =  length)){perror("ftruncate error");exit(-1);}}//如果你不满足默认挂接,这里给你提供接口自行挂接,同时你可以借助这个函数//且如果你传输的参数比现有的空间更大,那么会自动进行给你重新调整共享内存大小void* Map_POSIX(void* addr, size_t length, int prot, int flags,off_t offset){if(offset + length >_size){change_size(_size);}if(_attach){return _shm_ptr = (char*)mmap(addr,length,prot,flags,_shm_fd,offset);}else{std::cerr<<"还未创建/打开共享内存\n";}return nullptr;}~ShareMemory(){//解除映射并且关闭对象if(munmap(_shm_ptr,_size)==-1){perror("mumap");}//有关联时无法删除,因此每次析构都调用,不影响使用,也可以防止忘记if(shm_unlink(_pathname.c_str())==-1){perror("shm_unlink");}}
};

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

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

相关文章

L2-2 老板的作息表

新浪微博上有人发了某老板的作息时间表&#xff0c;表示其每天 4:30 就起床了。但立刻有眼尖的网友问&#xff1a;这时间表不完整啊&#xff0c;早上九点到下午一点干啥了&#xff1f; 本题就请你编写程序&#xff0c;检查任意一张时间表&#xff0c;找出其中没写出来的时间段…

web攻防基础

文章目录 网站的组成服务器中间件数据库源码 网站的架构目录型端口型多个站点 网站搭建对渗透有影响的技术站库分离CDNWAF 要进行渗透&#xff0c;首先我们需要对目标有一个清晰的认识&#xff0c;如果连网站有哪些东西&#xff0c;怎么构成都不知道&#xff0c;那你渗透个什么…

queue基础知识

queue 1.queue 1&#xff09; queue 的定义与结构 template <class T, class Container deque<T>> class queue; queue 是一个先进先出&#xff08;FIFO&#xff09;的数据结构&#xff1b; 其中T表示 stack 中存放的数据类型&#xff1b; Contaier&#xff…

Java中面向对象的继承性:初学者指南

Java中面向对象的继承性&#xff1a;初学者指南 在Java编程语言中&#xff0c;面向对象编程&#xff08;OOP&#xff09;的四大特性之一是继承性。继承允许我们创建新的类&#xff08;称为子类或派生类&#xff09;&#xff0c;这些类继承另一个类&#xff08;称为父类或基类&…

web按钮点击打开qt窗体

要在Web页面上的按钮点击时打开Qt窗体&#xff0c;你可以通过使用Qt的信号槽机制来实现。具体步骤如下&#xff1a; 1. 创建一个Qt窗体&#xff0c;例如一个简单的QWidget或者QDialog。 2. 在该窗体中添加你想要显示的内容和功能。 3. 在Web页面中创建一个按钮&#xff0c;并使…

nginx安装在linux上

nginx主要用于反向代理和负载均衡&#xff0c;现在简单的说说如何在linux操作系统上安装nginx 第一步&#xff1a;安装依赖 yum install -y gcc-c pcre pcre-devel zlib zlib-devel openssl openssl-devel 第二步&#xff1a; 下载nginx&#xff0c;访问官网&#xff0c;ngin…

加速催化剂设计,上海交大贺玉莲课题组基于 AutoML 进行知识自动提取

日常生活中&#xff0c;「催化」是最为常见的化学反应之一。比如&#xff0c;酿酒酿醋的本质&#xff0c;就是粮食中的淀粉在微生物酶的催化作用下&#xff0c;转变成酒精和醋酸的过程。 用更为学术的说法——在化学反应里能改变反应物反应速率&#xff08;既能提高也能降低&a…

51单片机工程模板的建立(基于STC15系列库)

一、开启前准备 1.STC15官方库文件 1.1 stc15-software-lib-v1.0.rar&#xff1b;下载地址&#xff1a;STC15系列库&#xff08;带使用手册&#xff09;资源-CSDN文库 2.Keil4_C51软件&#xff0c;或其它版本&#xff1b; 二、创建工程模板 1.建立文件分类 listing&#xf…

干货!微信小程序通过NodeJs连接MySQL数据库

在前后端数据库架构的思维中&#xff0c;微信小程序的生态地位是充当前端&#xff0c;后端和数据库还需开发者另外准备。微信开放社区提供强悍的云函数、云数据库、CMS内容管理&#xff0c;无疑为开发小程序的功能提供了不少便捷。 当我们在开发PC端的系统时&#xff0c;常见的…

Springboot+Vue项目-基于Java+MySQL的在线视频教育平台系统(附源码+演示视频+LW)

大家好&#xff01;我是程序猿老A&#xff0c;感谢您阅读本文&#xff0c;欢迎一键三连哦。 &#x1f49e;当前专栏&#xff1a;Java毕业设计 精彩专栏推荐&#x1f447;&#x1f3fb;&#x1f447;&#x1f3fb;&#x1f447;&#x1f3fb; &#x1f380; Python毕业设计 &…

Java中的容器,线程安全和线程不安全

Java中的容器主要指Java集合框架中的一系列类&#xff0c;它们提供了存储和操作对象的能力。在讨论容器的线程安全性时&#xff0c;我们可以将其分为两大类&#xff1a; 线程安全的容器&#xff1a; Vector: 这是ArrayList的线程安全版本&#xff0c;所有方法都被同步以确保在…

动态代理,XML,Dom4j

文章目录 动态代理概述特点代码实现实现的关键步骤优点 XML概述作用编写第一个XML文件组成声明元素(标签、标记)属性注释转义字符[实体字符字符区(了解) 约束DTD约束Schema约束名称空间 Dom4jXML解析解析方式和解析器解析方式解析器Snipaste_2024-04-17_21-22-44.png<br /&g…

视觉SLAM学习打卡【11】-尾述

到目前为止&#xff0c;视觉SLAM14讲已经到了终章&#xff0c;历时一个半月&#xff0c;时间有限&#xff0c;有些地方挖掘的不够深入&#xff0c;只能在后续的学习中更进一步。接下来&#xff0c;会着手ORB-SLAM2的开源框架&#xff0c;同步学习C。 视觉SLAM学习打卡【11】-尾…

Java27

FileOutputStream类 文件字节输出流FileOutputStream类是OutputStream类的子类write()方法顺序地向输出流写入字节&#xff0c;直到关闭输出流。 使用FileOutputStream类&#xff0c;操作本地文件地字节输出流&#xff0c;可以把程序中的数据写到本地文件中&#xff0c;其中写…

Java实现对称加密算法 DES/3DES/AES

一、DES加密算法 1.1 原理 DES是一种对称加密算法&#xff0c;它使用相同的密钥进行加密和解密操作。 DES算法的核心是一个称为Feistel网络的结构&#xff0c;它将明文分成左右两部分&#xff0c;并通过多轮迭代和替换操作来生成密文。 DES算法使用56位密钥&#xff08;实际…

基于SpringBoot+Vue的装饰工程管理系统(源码+文档+包运行)

一.系统概述 如今社会上各行各业&#xff0c;都喜欢用自己行业的专属软件工作&#xff0c;互联网发展到这个时候&#xff0c;人们已经发现离不开了互联网。新技术的产生&#xff0c;往往能解决一些老技术的弊端问题。因为传统装饰工程项目信息管理难度大&#xff0c;容错率低&a…

面试突击---MySQL索引

面试突击---MYSQL索引 面试表达技巧&#xff1a;1、谈一下你对于mysql索引的理解&#xff1f;&#xff08;为什么mysql要选择B树来存储索引&#xff09;2、索引有哪些分类&#xff1f;3、聚簇索引与非聚簇索引4、回表、索引覆盖、最左匹配原则、索引下推&#xff08;1&#xff…

概念解读稳定性保障

什么是稳定 百度百科关于稳定的定义&#xff1a; “稳恒固定&#xff1b;没有变动。” 很明显这里的“稳定”是相对的&#xff0c;通常会有参照物&#xff0c;例如 A 车和 B 车保持相同速度同方向行驶&#xff0c;达到相对平衡相对稳定的状态。 那么软件质量的稳定是指什么…

小白必看的Ubuntu20.04安装教程(图文讲解)

总的来说&#xff0c;安装Ubantu包含以下三个步骤&#xff1a; 一、安装虚拟机 二、Ubuntu镜像下载 三、虚拟机配置 一、安装虚拟机 选择安装VMware Workstation&#xff0c;登录其官网下载安装包&#xff0c;安装点这里。 下载后运行安装向导&#xff0c;一直Next即可。最…

2024腾讯一道笔试题--大小写字母移动

题目&#x1f357; 有一个字符数组,其中只有大写字母和小写字母,将小写字母移到前面, 大写字符移到后面,保持小写字母本身的顺序不变,大写字母本身的顺序不变, 注意,不要分配新的数组.(如:wCelOlME,变为wellCOME). 思路分析&#x1f357; 类似于冒泡排序&#xff0c;两两比较…