《Linux C编程实战》笔记:共享内存

news2024/9/24 15:26:41

共享内存是分配一块能被其他进程访问的内存。每个共享内存段在内核中维护一个内部数据结构shmid_ds(和消息队列、信号量一样),该结构定义在头文件linux/shm.h中,这是我从源码里抄的

#include<linux/shm.h>
struct shmid_ds {
	struct ipc_perm		shm_perm;	/* 操作许可 */
	int			shm_segsz;	/* size of segment (bytes) */
	__kernel_old_time_t	shm_atime;	/* 最后一个进程访问共享内存的时间 */
	__kernel_old_time_t	shm_dtime;	/* 最后一个进程离开共享内存的时间 */
	__kernel_old_time_t	shm_ctime;	/* last change time */
	__kernel_ipc_pid_t	shm_cpid;	/* pid of creator */
	__kernel_ipc_pid_t	shm_lpid;	/* pid of last operator */
	unsigned short		shm_nattch;	/* 当前使用该共享内存段的进程数量 */
	unsigned short 		shm_unused;	/* compatibility */
	void 			*shm_unused2;	/* ditto - used by DIPC */
	void			*shm_unused3;	/* unused */
};

但是总结了上一节的经验,我发现sys/shm.h也同样定义了该结构体,所以真正编写代码时可能只用包含sys/shm.h头文件

共享内存的创建与操作

共享内存区的创建

Linux下使用函数shmget来创建一个共享内存区,或者访问一个已经存在的共享内存区。该函数定义在头文件linux/shm.h中?

但是根据我自己的linux来看,linux/shm.h并没有该函数,在sys/shm.h中定义了该函数,所以以事实为准,认为该函数定义在sys/shm.h中。

并且根据实践,linux/shm.h和sys/shm.h同时包含的话编译不给过,所以下面就只用sys/shm.h了

#include <sys/shm.h>

int shmget(key_t key, size_t size, int shmflg);
  • key:用于标识共享内存段的关键字。
  • size:要创建的共享内存段的大小(以字节为单位)。
  • shmflg:用于指定创建共享内存段的访问权限和其他标志位。

返回值:

  • 如果成功,返回一个非负整数,该整数是共享内存段的标识符(即共享内存的ID)。
  • 如果失败,返回 -1,并设置 errno 来指示错误的原因。

该函数用法与消息队列和信号量集的创建一样。key一般通过ftok得到,shmflg的话一般是IPC_CREATE或者IPC_EXCL|IPC_CREATE 再加上权限的组合。具体含义请到消息队列的那一节查看:《Linux C编程实战》笔记:消息队列-CSDN博客

如果是创建的话,size要大于0;如果只是访问,size置为0.

共享内存区的操作

在使用共享内存区之前,必须通过shmat函数将其附加到进程的地址空间。进程与共享进程就建立了连接。shmat调用成功后就会返回一个指向共享内存区的指针,使用该指针就可以访问共享内存区了,如果失败返回-1.该函数定义在sys/shm.h中(这也是我根据实际改的,书上还是说是linux/shm.h)

#include <sys/shm.h>

void *shmat(int shmid, const void *shmaddr, int shmflg);
  • shmid:要连接的共享内存段的标识符(由 shmget 函数返回的ID)。
  • shmaddr:指定共享内存连接到进程地址空间的起始地址,通常设置为 NULL,让系统自动选择一个合适的地址。
  • shmflg:用于指定连接共享内存的选项,通常为0。

返回值:

  • 如果成功,返回一个指向共享内存段第一个字节的指针。
  • 如果失败,返回 (void *) -1,并设置 errno 来指示错误的原因。

当进程结束时使用共享内存区时,要通过函数shmdt断开与共享区内存的连接。该函数声明在sys/shm.h

#include <sys/shm.h>

int shmdt(const void *shmaddr);

参数shmaddr为shmget的返回值。该函数调用成功后,返回0,否则返回-1.进程脱离共享内存区后,数据结构shmid_ds中的shm_nattch就会减1.但是共享内存段依然存在,只有shm_nattch为0后,即没有任何进程再使用该共享内存区,共享内存区才应该在内核中被删除。一般来说,一个进程终止时,他所附加的共享内存区都会自动脱离。

共享内存区的控制

#include <sys/shm.h>

int shmctl(int shmid, int cmd, struct shmid_ds *buf);
  • shmid 是共享内存区的标识符,通常由 shmget 函数返回。
  • cmd 是要执行的操作,可以是各种控制命令之一。
  • buf 是一个指向 shmid_ds 结构的指针,用于传递或获取与共享内存相关的信息。

常用的控制命令包括:

  • IPC_STAT:获取共享内存区的状态信息,并将其存储在 buf 中。
  • IPC_SET:设置共享内存区的状态信息,buf 中包含了要设置的信息。
  • IPC_RMID:删除共享内存区。

如果你想删除共享内存区,可以将 cmd 参数设置为 IPC_RMID,并将共享内存区的标识符 shmid 作为 shmctl 函数,buf设置为NULL。

示例程序

本例通过读写者问题(不考虑优先级)来演示共享内存和呃呃信号量如何配合使用。这里的读者写者问题要求一个进程读共享内存的时候,其他进程不能写内存;当一个进程写共享内存的时候,其他进程不能读内存

首先定义了一个包含公用函数的头文件sharemem.h

#pragma once//这是C++的,毕竟我用的都是g++编译器
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/sem.h>
#include<sys/shm.h>
#include<errno.h>
#define SHM_SIZE 1024
union semun{
    int val;
    struct semid_ds *buf;
    unsigned short *array;
};
int createsem(const char *pathname,int proj_id,int members,int init_val){//创建信号量集
    key_t msgkey;
    int index,sid;
    union semun semopts;
    if((msgkey=ftok(pathname,proj_id))==-1){
        perror("ftok error!\n");
        return -1;
    }
    if((sid=semget(msgkey,members,IPC_CREAT|0666))==-1){//创建信号量集
        perror("semget call failed.\n");
        return -1;
    }
    semopts.val=init_val;
    for(index=0;index<members;index++){
        semctl(sid,index,SETVAL,semopts);//设置信号量的初值
    }
    return sid;
}
int opensem(const char *pathname,int proj_id){//打开信号量集
    key_t msgkey;
    int sid;
    if((msgkey=ftok(pathname,proj_id))==-1){
        perror("ftok error!\n");
        return -1;
    }
    if((sid=semget(msgkey,0,IPC_CREAT|0666))==-1){
        perror("semget call failed.\n");
        return -1;
    }
    return sid;//返回信号量集的id
}
int sem_p(int semid,int index){//p操作,消耗信号量
    struct sembuf buf={0,-1,IPC_NOWAIT};
    if(index<0){
        perror("index of array cannot equals a minus value");
        return -1;
    }
    buf.sem_num=index;
    if(semop(semid,&buf,1)==-1){
        perror("a wrong operation to semaphore occurred!");
        return -1;
    }
    return 0;
}
int sem_v(int semid,int index){//v操作,增加信号量
    struct sembuf buf={0,+1,IPC_NOWAIT};
    if(index<0){
        perror("index of array cannot equals a minus value");
        return -1;
    }
    buf.sem_num=index;
    if(semop(semid,&buf,1)==-1){
        perror("a wrong operation to semaphore occurred!");
        return -1;
    }
    return 0;
}
int sem_delete(int semid){//删除信号量集
    return semctl(semid,0,IPC_RMID);
}
int wait_sem(int semid,int index){//等待信号量
    while (semctl(semid,index,GETVAL)==0)//如果信号量等于0,也就是没有资源,就等待
    {
        sleep(1);
    }
    return 1;
}
int createshm(const char *pathname,int proj_id,size_t size){//创建共享内存
    key_t shmkey;
    int sid;
    if((shmkey=ftok(pathname,proj_id))==-1){
        perror("ftok error!\n");
        return -1;
    }
    if((sid=shmget(shmkey,size,IPC_CREAT|0666))==-1){
        perror("shmget call failed.\n");
        return -1;
    }
    return sid;
}

writer和reader程序,两程序在进入共享内存区之前,都要检查信号量的值是否为1(相当于是否能进入共享内存区),如果不为1,调用sleep()进入睡眠状态直到信号值变为1。进入共享内存区之后,将信号的值减1(相当于加锁),这样就实现了互斥的访问共享资源。在退出共享内存区的时候,将信号量加1(相当于解锁)。

writer:

#include"sharemem.h"
#include<string.h>
int main(){
    int semid,shmid;
    char *shmaddr;
    char write_str[SHM_SIZE];
    if((shmid=createshm(".",'m',SHM_SIZE))==-1){//创建或打开共享内存
        exit(1);
    }
    if((shmaddr=(char *)shmat(shmid,NULL,0))==(char *)-1){//获取共享内存的地址
        perror("attach shared memory error!\n");
        exit(1);
    }
    if((semid=createsem(".",'s',1,1))==-1){//创建信号量集
        exit(1);
    }
    while(1){
        wait_sem(semid,0);//先等信号量解锁
        sem_p(semid,0);//在获取资源,给信号量上锁
        printf("writer:");
        fgets(write_str,1024,stdin);//从标准输入读入
        int len=strlen(write_str)-1;
        write_str[len]='\0';
        strcpy(shmaddr,write_str);//写入共享内存
        sleep(10);
        sem_v(semid,0);//解锁
        sleep(10);
    }
}

reader:

#include"sharemem.h"
#include<string.h>
int main(){
    int semid,shmid;
    char *shmaddr;
    char write_str[SHM_SIZE];
    if((shmid=createshm(".",'m',SHM_SIZE))==-1){
        exit(1);
    }
    if((shmaddr=(char *)shmat(shmid,NULL,0))==(char *)-1){
        perror("attach shared memory error!\n");
        exit(1);
    }
    if((semid=opensem(".",'s'))==-1){//打开信号量集
        exit(1);
    }
    while(1){
        printf("reader:");
        wait_sem(semid,0);
        sem_p(semid,0);
        printf("%s\n",shmaddr);//读入共享内存
        
        sleep(10);
        sem_v(semid,0);
        sleep(10);
    }
}

编译,因为是自己编写的头文件,需要加-I选项,这里我的头文件和cpp文件是同一路径,所以用的就是.,请根据自己的路径来。

最后在运行

reader会在writer发送信息10s后打印信息。

写在最后

由于本人要考研了,播客可能不会再长更。这本《Linux C编程实战》其实也差不多完结了,还剩网络编程章节没有讲,我肯定是没时间讲了,可能考研失败了会回来继续。《Primer C++》的课后题还有第八章的存货,后续章节只能随缘更新。Qt部分真烂尾了,写Qt项目的注释实在太累了。最有可能更新的部分是力扣题讲解,因为写来准备复试上机。

最后祝大家,也祝我一切顺利

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

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

相关文章

pytorch基础2-数据集与归一化

专题链接&#xff1a;https://blog.csdn.net/qq_33345365/category_12591348.html 本教程翻译自微软教程&#xff1a;https://learn.microsoft.com/en-us/training/paths/pytorch-fundamentals/ 初次编辑&#xff1a;2024/3/2&#xff1b;最后编辑&#xff1a;2024/3/2 本教程…

swagger在java中的基本使用

自动生成接口文档&#xff0c;和在线接口测试的框架。 导入依赖 <!-- knife4j对swagger进行一个封装--><dependency><groupId>com.github.xiaoymin</groupId><artifactId>knife4j-spring-boot-starter</artifactId><versi…

StarCoder2本地部署上手体验:程序猿要下岗了吗?

StarCoder2简介 ServiceNow、Hugging Face 和 NVIDIA 于2月28日宣布发布 StarCoder2&#xff0c;这是一个用于代码生成的开放式大型语言模型系列&#xff0c;为性能、透明度和成本效益设定了新标准。StarCoder2 是与 BigCode 社区合作开发的&#xff0c;由ServiceNow和 Huggin…

labview数组精讲

题主经过写文章一段时间的发现,许多同学对该软件的理解和编程能力是不太一样的,有些知识相对一些同学较为简单,但是有些同学提问就比较困难。那么针对这个问题,题主打算出一期说白话系列的专栏,在该栏目中用最通俗的大白话和例子去让大家深刻了解这个软件的功能和摸透他的…

Py2neo查询neo4j周杰伦数据库中的节点、关系和路径教程

文章目录 py2neo介绍连接Neo4j数据库py2neo查询图数据库neo4j数据概览使用NodeMatcher查询节点使用RelationshipMatcher查询关系 通过执行Cypher语句查询 py2neo介绍 Neo4j是一款开源图数据库&#xff0c;Py2neo提供了使用Python语言访问Neo4j的接口。本文介绍了使用Py2neo的N…

钉钉机器人发送折线图卡片 工具类代码

钉钉机器人 “创建并投放卡片 接口 ” 可以 发送折线图、柱状图 官方文档&#xff1a;创建并投放卡片 - 钉钉开放平台 0依赖、1模板、2机器人放到内部应用、3放开这个权限 、4工具类、5调用工具类 拼接入参 卡片模板 自己看文档创建&#xff0c;卡片模板的id 有用 0、依赖…

vue2 设置keepAlive之后怎么刷新页面数据

场景&#xff1a;移动端有 A、B、C 三个页面&#xff0c;A、B 页面路由设置了keepAlive属性&#xff0c;有下面两个场景&#xff1a; 1、A 页面 --> B 页面&#xff0c;B 页面刷新。 2、C 页面 --> B页面&#xff0c;B 页面不刷新。 一、分为以下两个情况讨论&#xf…

Linux安装Nginx配置Keepalived高可用

Vmwaire 安装 Linux 解决启动没有IP地址问题 cd /etc/sysconfig/network-scripts vi ifcfg-ens33# 重启linux reboot # 再次查看ip ip addrLinux 镜像地址下载 ps: 发现阿里有一个工具箱&#xff0c;里面有各种镜像 阿里镜像地址 https://developer.aliyun.com/mirror/ 安装…

计算机设计大赛 深度学习图像修复算法 - opencv python 机器视觉

文章目录 0 前言2 什么是图像内容填充修复3 原理分析3.1 第一步&#xff1a;将图像理解为一个概率分布的样本3.2 补全图像 3.3 快速生成假图像3.4 生成对抗网络(Generative Adversarial Net, GAN) 的架构3.5 使用G(z)生成伪图像 4 在Tensorflow上构建DCGANs最后 0 前言 &#…

windows安装部署node.js以及搭建运行第一个Vue项目

一、官网下载安装包 官网地址&#xff1a;https://nodejs.org/zh-cn/download/ 二、安装程序 1、安装过程 如果有C/C编程的需求&#xff0c;勾选一下下图所示的部分&#xff0c;没有的话除了选择一下node.js安装路径&#xff0c;直接一路next 2、测试安装是否成功 【winR】…

cv_bridge连接自定义版本的opencv

在ros noetic版本中&#xff0c;默认的cv_bridge依赖的opencv版本为4.2.0&#xff0c;若要升级opencv版本&#xff0c;则无法使用cv_bridge&#xff0c;所以需要重新自编译cv_bridge。 一. 编译cv_bridge 1.通过网站 https://github.com/ros-perception/vision_opencv/tree/n…

MYSQL的优化学习,从原理到索引,在到事务和锁机制,最后的主从复制、读写分离和分库分表

mysql的优化学习 为什么选择Mysql不选择其他的数据库&#xff1f;还有哪些&#xff0c;有什么区别&#xff1f; Mysql&#xff1a;开源免费版本可用&#xff0c;适用于中小型应用 Oracle&#xff1a;适用于大型企业级应用&#xff0c;复杂的业务场景和大量数据的处理&#xf…

Acwing 每日一题 空调 差分 贪心

&#x1f468;‍&#x1f3eb; 空调 &#x1f468;‍&#x1f3eb; 参考题解 import java.util.Scanner;public class Main {static int N (int) 1e5 10;static int[] a new int[N];static int n;public static void main(String[] args){Scanner sc new Scanner(System.…

智能家居控制系统(51单片机)

smart_home_control_system 51单片机课设&#xff0c;智能家居控制系统 使用及转载请标明出处&#xff08;最好点个赞及star哈哈&#xff09; Github地址&#xff0c;带有PPT及流程图 Gitee码云地址&#xff0c;带有PPT及流程图 ​ 以STC89C52为主控芯片&#xff0c;以矩阵键…

【OpenCV C++】Mat img.total() 和img.cols * img.rows 意思一样吗?二者完全相等吗?

文章目录 1 结论及区别2 Mat img的属性 介绍1 结论及区别 在大多数情况下,img.total() 和 img.cols * img.rows 是相等的,但并不总是完全相等的。下面是它们的含义和一些区别: 1.img.total() 表示图像中像素的总数,即图像的总像素数量。2.img.cols * img.rows 也表示图像中…

C++学习笔记:二叉搜索树

二叉搜索树 什么是二叉搜索树?搜索二叉树的操作查找插入删除 二叉搜索树的应用二叉搜索树的代码实现K模型:KV模型 二叉搜索树的性能怎么样? 什么是二叉搜索树? 二叉搜索树又称二叉排序树&#xff0c;它或者是一棵空树&#xff0c;或者是具有以下性质的二叉树: 若它的左子树…

【go语言开发】swagger安装和使用

本文主要介绍go-swagger的安装和使用&#xff0c;首先介绍如何安装swagger&#xff0c;测试是否成功&#xff1b;然后列出常用的注释和给出使用例子&#xff1b;最后生成接口文档&#xff0c;并在浏览器上测试 文章目录 安装注释说明常用注释参考例子 文档生成格式化文档生成do…

代码随想录算法训练营第二十八天|93.复原IP地址 、78.子集、90.子集II

文章目录 [1.复原 IP 地址](https://leetcode.cn/problems/restore-ip-addresses/description/)2.子集[3.子集 II](https://leetcode.cn/problems/subsets-ii/) 1.复原 IP 地址 切割问题可以使用回溯&#xff0c;本题分别两步&#xff0c;切割字符串和判断IP 切割逻辑如下&…

微信小程序 --- 分包加载

分包加载 1. 什么是分包加载 什么是分包加载 ❓ 小程序的代码通常是由许多页面、组件以及资源等组成&#xff0c;随着小程序功能的增加&#xff0c;代码量也会逐渐增加&#xff0c;体积过大就会导致用户打开速度变慢&#xff0c;影响用户的使用体验。 分包加载是一种小程序…

MATLAB图像噪声添加与滤波

在 MATLAB 中添加图像噪声和进行滤波通常使用以下函数&#xff1a; 添加噪声&#xff1a;可以使用imnoise函数向图像添加各种类型的噪声&#xff0c;如高斯噪声、椒盐噪声等。 滤波&#xff1a;可以使用各种滤波器对图像进行滤波处理&#xff0c;例如中值滤波、高斯滤波等。 …