【Linux】进程间通信之-- 共享内存与信号量的介绍(下)

前言
上一篇,我们由进程间通信,引入并讲述了管道、匿名管道和命名管道,本节,将继续学习进程间通信的另一种方式之,共享内存。还要学习几个系统调用接口,并演示两个进程通过共享内存来进行通信。。。

目录

    • 1.共享内存
    • 1.1 创建共享内存
      • 1.1 ftok()创建key值
      • 1.2 shmget函数
      • 1.3 ipcs指令查看共享内存资源
      • 1.4 shmctl()接口
      • 1.5 shmat()接口
      • 1.6shmdt函数接口
      • 1.7 共享内存总结
      • 1.8 通过管道对共享内存进行控制:
    • 2. 相关概念
    • 3. 信号量
      • 3. 1 信号量的分类
      • 3. 2 信号量的原子性说明
      • 3. 3 信号量的规则

1.共享内存

本节讲的是system V的共享内存。

共享内存区是最快的IPC形式。一旦这样的内存映射到共享它的进程的地址空间,这些进程间数据传递不再涉及到内核,换句话说是进程不再通过执行进入内核的系统调用来传递彼此的数据.

共享内存示意图
在这里插入图片描述

  • 我们知道堆栈相对而生,堆从低地址向高地址生长,栈从高地址向低地址生长,而在这两块空间之间的则是共享区。
    堆栈之间的区域特别大,堆栈之间的区域称为共享区,其中共享库就在这里。

共享内存的实现:

  1. 在物理空间上创建共享内存(申请一段空间)。
  2. 通过两个进程调用接口,然后物理内存中的空间映射到自己的地址空间上。

进程间通信的前提是:先让不同的进程,看到同一份资源

  • 共享内存是一种进程间通信机制,它允许多个进程共享同一块物理内存区域(就能同时看到一份资源)。

  • 当一个进程向共享内存写入数据时,实际上是将数据直接写入到共享内存所对应的物理内存中。

  • 其他进程可以通过读取相同的共享内存区域来获取已写入的数据。

优点:

  • 与其他进程间通信方式(如管道、消息队列等)不同。
  • 共享内存避免了数据的复制和传输过程,因此具有较高的效率。
  • 可以提供快速的数据交换,特别适用于需要频繁共享大量数据的进程间通信场景

共享内存数据结构

在这里插入图片描述

1.1 创建共享内存

共享内存=共享内存块+对应的共享内存的内核数据结构!

1.1 ftok()创建key值

  • 共享内存存在哪里?

  • 共享内存提供者,是操作系统

  • 存在于内核中,内核会给我们维护共享内存的结构

  • 操作系统也需要管理共享内存,一定是先描述,再组织

  • 我怎么知道,这个共享内存是存在还是不存在?

  • 需要标识共享内存的唯一性!

  • 在内核中,让不同的进程看到同一份共享内存。。

  • 做法是:让他们拥有同一个key即可。。

为了实现这种共享,操作系统会给每个共享内存区域分配一个唯一的key值来标识它,其他进程可以通过这个key值来访问并操作该共享内存区域。
这样就可以实现多个进程之间的数据交换和共享。

创建key值的函数:
在这里插入图片描述

返回值:key_t(其实就是int类型)成功了返回key值,失败了就返回-1
  • Linux系统给定了ftok接口,将用户提供的pathname工作路径,以及proj_id项目编号转换为一个共享内存的key(其实就是int类型)
  • 底层会将第一个参数对应路径文件的inode和指定的项目id这两个数字做组合形成一个唯一值,返回给一个key。
    底层是一些列的算法设计,相当于是帮我们构建具有唯一性的数字就可以了。

1.2 shmget函数

功能:用来创建共享内存
原型
int shmget(key_t key, size_t size, int shmflg);
参数
key:这个共享内存段名字
size:共享内存大小(建议设置成页(4KB)的正式倍
shmflg:由九个权限标志构成,它们的用法和创建文件时使用的mode模式标志是一样的返回值:成功返回一个非负整数,即该共享内存段的标识码;失败返回-1
共享内存的用户层标识符shmid,类似于曾经的fd,

操作系统和磁盘lO的基本单位大小是4KB。
从磁盘拷贝到内存是以4KB为单位拷贝的。
所以共享内存在申请大小时,也一定是4KB的整数倍。
操作系统只会按照整4KB来申请共享内存,是向上取整。

shmflg参数设置解释:

  • IPC_CREAT:创建共享内存,如果已经存在,就获取之,不存在就创建之。
    注: 可以获取成功,但是不知道这个共享内存,是本进程创建还是别的进程创建的拿过来的。
  • IPC_EXCL:必须配合IPC_CREAT使用(用按位或|配合使用),如果不存在指定的共享内存,创建之,如果存在了,出错返回。
    注:核心作用: 可以保证,如果shmget函数调用成功,一定是一个全新的share memory(共享内存)。
    如果这两个选项合着一起配合使用,一起传, 只要函数调用成功了,得到的一定是个全新的共享内存
  • 0666或权限值: 指定共享内存的访问权限。这些权限值使用八进制表示,例如0666表示可读可写权限。

key参数说明:

  • key值得由用户来提供。
  • 如果key值是由操作系统统一提供的话,另一个进程是无法获得共享内存的key值的。

1.3 ipcs指令查看共享内存资源

通过上述讲解,我们只要获取到唯一的key值,调用shmget函数就能获得共享内存了,创建好了我们怎样才能知道有哪些IPC资源呢。
ipcs指令的几个选项:

ipcs -c #查看消息队列/共享内存/信号量
ipcs -s #单独查看信号量
ipcs -q #单独查看消息队列
ipcs -m #单独查看共享内存

ipcrm -m 删除共享内存:

  • 只要在指令后跟上自己要删除的共享内存的shmid值就可以了
  • 为什么删除共享内存要用shmid而不用key呢?

key是操作系统中用来标识共享内存唯一性的, 在用户层用的是shmid
在用户层访问共享内存只能用数字shmid。

1.4 shmctl()接口

shmctl这个函数可以用于操作共享内存:

功能:用于控制共享内存
原型
int shmctl(int shmid, int cmd, struct shmid_ds *buf);
参数
shmid:由shmget返回的共享内存标识码
cmd:将要采取的动作(有三个可取值)
buf:指向一个保存着共享内存的模式状态和访问权限的数据结构
返回值:成功返回0;失败返回-1

第二个参数解释:
IPC_STAT:用于获取共享内存段的状态信息,包括共享内存段大小、访问权限等。
IPC_SET:用于设置共享内存段的状态信息,如更改访问权限、起始地址等。
IPC_RMID:用于删除共享内存段,释放相关的资源

第三个参数:如果IPC_RMID如果被设置了,shmid_ds设置成nullptr就可以了,还有一些其他的属性设置

 shmctl(shmid, IPC_RMID, NULL)

注意:
当进程运行结束,我们的共享内存,还存在的。
需要使用shmctl( )函数手动删除。

1.5 shmat()接口

at是attach的简写,把一个共享内存附在进程上

功能:将共享内存段连接到进程地址空间
原型
void *shmat(int shmid, const void *shmaddr, int shmflg);
参数
shmid: 共享内存标识
shmaddr:指定连接的地址
shmflg:它的两个可能取值是SHM_RND和SHM_RDONLY
返回值:成功返回一个指针,指向共享内存第一个节;失败返回-1

说明:

shmaddr为NULL,核心自动选择一个地址 shmaddr不为NULL且shmflg无SHM_RND标记,则以shmaddr为连接地址。
shmaddr不为NULL且shmflg设置了SHM_RND标记,则连接的地址会自动向下调整为SHMLBA的整数倍。公式:shmaddr -
(shmaddr % SHMLBA) shmflg=SHM_RDONLY,表示连接操作用来只读共享内存

char *addr = shmat(shmid, NULL, 0)

补充注意事项

  • 因为shmat函数的返回值是一个void*类型的指针,所以我们就可以像使用malloc一样的方式使来挂接共享内存了。
  • 随后对这个共享内存的操作就像平时使用数组一样的方式来使用了。
  • 共享内存是一种特殊的内存区域,可以由多个进程同时访问。
  • 尽管共享内存由一个进程创建,但它并不属于任何一个特定的进程。

同样的道理另一个进程也需要挂接这个共享内存才能实现两个进程通过共享内存来进行通信.

1.6shmdt函数接口

dt是detach的简写,把一个共享内存从进程上脱离下来(去关联)。

功能:将共享内存段与当前进程脱离
原型
int shmdt(const void *shmaddr);
参数
shmaddr: 由shmat所返回的指针
返回值:成功返回0;失败返回-1
注意:将共享内存段与当前进程脱离不等于删除共享内存段

1.7 共享内存总结

  • 可以将共享内存当成一个大字符串
  • 只要是通信双方使用shm,一方直接向共享内存中写入数据,另一方,就可以立马看到。 共享内存是所有进程间通信(IPC)里速度最快的!,不需要过多的拷贝
  • 共享内存缺乏访问控制!会带来并发问题。因为有临界区资源问题,要做到同步

管道通信过程演示:

  • 管道的通信,使用了read/write函数,会有访问控制,一共经历4次拷贝。。

在这里插入图片描述

1.8 通过管道对共享内存进行控制:

Log.hpp:

#pragma once#include <iostream>
#include <ctime>std::ostream &Log()
{std::cout << "For Debug | " << "timestamp: " << (uint64_t)time(nullptr) << " | ";return std::cout;
}

Comm.hpp:

#pragma once#include <iostream>
#include <cstdio>
#include <cstring>
#include <cerrno>
#include <cstdlib>
#include <cassert>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/fcntl.h>
#include "Log.hpp"using namespace std;#define PATH_NAME "/home/Zh_Ser/linux"
#define PROJ_ID 0x14
#define MEM_SIZE 4096#define FIFO_FILE "./.fifo"// hpp是将头文件和源文件写在一起的方式
// 函数的定义可以放在里面,一般在开源的项目里用key_t CreateKey()
{key_t key = ftok(PATH_NAME, PROJ_ID);if (key < 0){cerr << "ftok: " << strerror(errno) << endl;exit(1);}return key;
}// 创建命名管道
void CreatFifo()
{umask(0);if (mkfifo(FIFO_FILE, 0666) < 0){Log() << strerror(errno) << endl;exit(2);}
}#define READER O_RDONLY
#define WRITER O_WRONLYint Open(const string& filename, int flags)
{return open(filename.c_str(), flags);
}int Wait(int fd)
{uint32_t values = 0;ssize_t s = read(fd, &values, sizeof(values));return s;
}void Signal(int fd)
{uint32_t cmd = 1;int s = write(fd, &cmd, sizeof(cmd));
}void Close(int fd, const string filename)
{close(fd);unlink(filename.c_str());
}

IpcShmClient.cpp:

#include "Comm.hpp"
#include "Log.hpp"// 充当使用共享内存的角色
int main()
{int fd = Open(FIFO_FILE, WRITER);cout << "Client: " << fd << endl;// 创建相同的key值key_t key = CreateKey();Log() << "key: " << key << endl;// 等待Server端先创建共享内存sleep(1);// 获取共享内存int shmid = shmget(key, MEM_SIZE, IPC_CREAT);if (shmid < 0){Log() << "IpcShmCli shmget: " << strerror(errno) << endl;return 2;}// 挂接char* addr= (char*)shmat(shmid, nullptr, 0);// sleep(5);// 用它// 用共享内存,竟然没有使用任何系统调用接口// 直接向str空间写入while (true){printf("Please Enter# ");fflush(stdout);// 往共享内存写数据ssize_t s = read(0, addr, MEM_SIZE);if (s > 0){str[s] = '\0';}Signal(fd);}// 去关联shmdt(addr);// 不需要删除return 0;
}

IpcShmServer.cpp

#include "Comm.hpp"
#include "Log.hpp"// 创建全新的共享内存
const int flags = IPC_CREAT | IPC_EXCL;// 充当创建共享内存的角色
int main()
{// 创建管道CreatFifo();int fd = Open(FIFO_FILE, READER);cout << "Server: " << fd << endl;assert(fd >= 0);// 创建Keykey_t key = CreateKey();Log() << "key: " << key << endl;Log() << "create share memory begin" << endl;int shmid = shmget(key, MEM_SIZE, flags | 0666);if (shmid < 0){Log() << "IpcShmSer shmget: " << strerror(errno) << endl;return 2;}Log() << "create shm success, shmid: " << shmid << endl;// 1. 将共享内存和自己的进程产生关联attchchar* addr= (char*)shmat(shmid, nullptr, 0);Log() << "attach shm: " << shmid << "success" << endl;// 用它// 服务器端直接用while (true){sleep(1);// 在管道当中等,让读端进行等待if (Wait(fd) <= 0) break;// 从共享内存里读数据printf("%s\n", addr);}// **2. 去关联shmdt的返回值就是shmat的返回值**shmdt(addr);Log() << "detach shm: " << shmid << "success" << endl;// 删除shmctl(shmid, IPC_RMID, nullptr);Log() << "delete shm: " << shmid << "success" << endl;Close(fd, FIFO_FILE);return 0;
}

基于共享内存 + 管道的一个访问控制的效果:

  • 管道本身提供保护机制,我们自己也做了一次保护机制共享内存 + 管道的机制。
  • 如果这两个方案都不提供,裸的共享内存,被双方同时看到。
  • 我们两个进程在操作,就可能出现一些来回读写交叉的问题。
  • 导致数据不一致的问题,或者是访问控制方面的问题。

2. 相关概念

  • 临界资源: 被多个进程能够看到的资源叫做临界资源。

  • 如果没有对临界资源进行任何保护,对于临界资源的访问。

  • 多方进程在进行访问的时候,就都是乱序的。

  • 可能会因为读写交叉而导致的各种乱码、废弃数据、访问控制方面的问题!!

  • 临界资源有安全的也有不安全的,取决于内部是否做了保护。

  • 临界区: 我们把自己的进程,访问临界资源的代码

  • 我的进程代码中,有大量的代码,只有一部分代码,会访问临界资源。

  • 两个进程分别对共享资源做读写的代码叫做它们俩的临界区。

  • 原子性: 我们把一件事情,要么不做,要么做完,没有中间状态,叫原子性。

  • 如果一个n–操作只有一行汇编,该操作就是原子性的。

  • 互斥: 在任何时刻,都只能有一个进程进入临界区–互斥!!

3. 信号量

信号量(Semaphore)是一种在并发编程中常用的同步机制,用于控制对共享资源的访问。本质上就是一个整数计数器,用于表示可用资源的数量。

  • 信号量也属于进程间通信的一种,只不过不是以传送数据为目的,而是控制双方协同步调为目的。

多进程可以访问临界资源的不同区域,就要保证:

  1. 信号量保证不会有多余的进程连接到这份临界资源。
  2. 还需要保证每一个进程的能够访问到临界资源的不同位置(根据上层业务决定)

3. 1 信号量的分类

  • 二元信号量: 要么为0要么为1,(表现为互斥特性)。
  • 多元信号量:这个信号量可能为十八九等(一般很少见)。

如果一个进程想访问由信号量控制的临界资源,必须先申请信号量。如果申请成功,就一定能访问到这个临界资源中的一部分。

3. 2 信号量的原子性说明

每一个进程,要先申请信号量,每一个进程,都必须,先看到这个信号量:
信号量本身就是临界资源那么问题来了谁来保护信号量呢?

我们的信号量为了保证能够正确的控制进程的访问,其就必须维护自身的原子性!不能有中间状态
信号量本身是原子性的

共享内存不做访问控制,可以通过信号量进行对资源保护!

3. 3 信号量的规则

信号量对应的操作是PV操作:

  • 申请资源:P
  • 释放资源:V
    在这里插入图片描述

尾声
看到这里,相信大家对这个Linux 有了解了。
如果你感觉这篇博客对你有帮助,不要忘了一键三连哦

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

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

相关文章

工业控制:CANOpen(控制器局域网络)协议快速学习

文章目录 背景协议介绍CAN总线协议CANOpen协议介绍CANOpen诞生背景CANOpen的对象字典 CANOpen的服务数据对象&#xff08;SDO&#xff09; 参考附录问题CAN总线竞争原理在CAN协议中&#xff0c;帧中的ID是发送者的ID还是接收者的ID&#xff1f; 背景 目前很多CANOpen介绍的文章…

循环机制(event loop)之宏任务和微任务

一、前言 js任务分为同步任务和异步任务&#xff0c;异步任务又分为宏任务和微任务&#xff0c;其中异步任务属于耗时的任务。 二、宏任务和微任务有哪些&#xff1f; 宏任务&#xff1a;整体代码script、setTimeout、setInterval、setImmediate&#xff08;Node.js&#xff…

【ARM】SMMU系统虚拟化整理

目录 1.MMU的基本介绍 1.1 特点梳理 2.功能 DVM interface PTW interface 2.1 操作流程 2.1.1 StreamID 2.1.2 安全状态&#xff1a; 2.1.3 HUM 2.1.4 可配置的操作特性 Outstanding transactions per TBU QoS 仲裁 2.2 Cache结构 2.2.1 Micro TLB 2.2.2 Macro…

第四周:机器学习笔记

第四周学习周报 摘要Abstract机器学习任务攻略1.loss on training data1.1 training data的loss过大怎么办&#xff1f;1.2 training data的loss小&#xff0c;但是testing data loss大怎么办&#xff1f; 2. 如何选择一个中最好的模型&#xff1f;2.1 Cross Validation&#x…

知名在线市场 Etsy 允许在其平台上销售 AI 艺术品,但有条件限制|TodayAI

近日&#xff0c;以手工和复古商品著称的在线市场 Etsy 宣布&#xff0c;将允许在其平台上销售 AI 生成的艺术品。这一举措引发了广泛关注和争议。尽管 Etsy 正在接受 AI 艺术的潮流&#xff0c;但平台对这一类商品的销售设置了一些限制。 根据 Etsy 新发布的政策&#xff0c;…

mysql存储引擎和备份

索引 事务 存储引擎 概念&#xff1a;存储引擎&#xff0c;就是一种数据库存储数据的机制&#xff0c;索引的技巧&#xff0c;锁定水平。 存储引擎。存储的方式和存储的格式。 存储引擎也属于mysql当中的组件&#xff0c;实际上操作的&#xff0c;执行的就是数据的读写I/O。…

华为OD机试2024年C卷D卷 - 构成指定长度字符串的个数/字符串拼接(Java)

华为OD机试&#xff08;C卷D卷&#xff09;2024真题目录 题目描述&#xff1a;构成指定长度字符串的个数 (本题分值200) 给定 M&#xff08;0 < M ≤ 30&#xff09;个字符&#xff08;a-z&#xff09;&#xff0c;从中取出任意字符&#xff08;每个字符只能用一次&#x…

科普文:银行信贷系统概叙

信贷业务流程 资金需求者提交申请&#xff1a;资金需求者通过不同渠道&#xff08;如APP、网站、门店等&#xff09;提交贷款申请。 系统交互完成审批&#xff1a;系统通过自动化和人工相结合的方式&#xff0c;对贷款申请进行初步筛选和审批。 系统交互完成策略判断&#xf…

rsync文件远程同步

目录 一、什么是rsync远程同步 二、实操rsync远程文件同步 1、配置rsync同步源 2、客户端部署 3、增量备份​编辑 4、删除文件 5、如何实现免交互登录 6、crontab rsync 实现定时同步 7、使用ssh实现rsync数据同步【☆】 如何使用ssh免交互实现数据同步&#xff1f;…

Golang | Leetcode Golang题解之第260题只出现一次的数字III

题目&#xff1a; 题解&#xff1a; func singleNumber(nums []int) []int {xorSum : 0for _, num : range nums {xorSum ^ num}lsb : xorSum & -xorSumtype1, type2 : 0, 0for _, num : range nums {if num&lsb > 0 {type1 ^ num} else {type2 ^ num}}return []in…

【深度学习入门篇 ⑨】循环神经网络实战

【&#x1f34a;易编橙&#xff1a;一个帮助编程小伙伴少走弯路的终身成长社群&#x1f34a;】 大家好&#xff0c;我是小森( &#xfe61;ˆoˆ&#xfe61; ) &#xff01; 易编橙终身成长社群创始团队嘉宾&#xff0c;橙似锦计划领衔成员、阿里云专家博主、腾讯云内容共创官…

【一刷《剑指Offer》】面试题 48:不能被继承的类

《剑指Offer》对应内容&#xff1a; 可参考&#xff1a; 【C】继承 -- 详解_c,两个派生类继承一个基类,声明对象的时候用基类的对象。-CSDN博客

每日OJ_牛客_WY33 计算糖果

目录 牛客_WY33 计算糖果 解析代码 牛客_WY33 计算糖果 计算糖果_牛客题霸_牛客网 解析代码 A - B aB - C bA B cB C d 这道题目的实质是&#xff1a;判断三元一次方程组是否有解及求解&#xff0c; 13可以得到A(ac)/2&#xff1b;4-2可以得到C(d-b)/2; 24可以得到B2…

WebGSI地图切片|栅格地图切片原理|地图矢量切片原理

介绍 图栅格切片是WebGIS中使用的一种新技术&#xff0c;通过地图栅格切片可以有效缩短服务器的地图生成时间和地图传输时间&#xff0c;提高系统的响应速度。 地图切片是在多个比例尺下配置地图&#xff0c;预先将每个比例尺下的地图绘制成小图片&#xff0c;保存到服务器上一…

Python 爬虫实战----3(实力展现)

实战&#xff1a;获取豆瓣电影top250的电影名字 1.获取url&#xff1a;打开网站按发f12&#xff0c;点击网络&#xff0c;刷新找到第一个截取url和User-Agent。 2.请求爬取数据 mport requests import fake_useragent from lxml import etree import re #UA head {"User…

Android AutoSize屏幕适配:适配不同屏幕大小的尺寸,让我们无需去建立多个尺寸资源文件

目录 AutoSize是什么 AutoSize如何使用 一、AndroidautoSize是什么 在开发产品的时候&#xff0c;我们会遇到各种各样尺寸的屏幕&#xff0c;如果只使用一种尺寸去定义控件、文字的大小&#xff0c;那么到时候改起来就头皮发麻。以前使用dime的各种类库&#xff0c;文件太多…

Spark调优特殊case- Task倾斜

首先我们观察下上面的stage5, Task MaxTime2.4Min, 但是stage5的整体耗时竟然可以达到55Min, 其实分区1000&#xff0c; 300个executor&#xff0c; 按照最大的TaskTime2.4Min来估算所有Task运行完成时间, 那么时间应该是- 2.4Min * 3 2.4Min 9.6Min 也就是最慢也就跑10分钟就…

C++ | Leetcode C++题解之第274题H指数

题目&#xff1a; 题解&#xff1a; class Solution { public:int hIndex(vector<int>& citations) {int left0,rightcitations.size();int mid0,cnt0;while(left<right){// 1 防止死循环mid(leftright1)>>1;cnt0;for(int i0;i<citations.size();i){if(…

Kubernetes集群安装步骤

前言&#xff1a;本博客仅作记录学习使用&#xff0c;部分图片出自网络&#xff0c;如有侵犯您的权益&#xff0c;请联系删除 一、安装要求 在开始之前&#xff0c;部署Kubernetes集群集群需要满足以下几个条件&#xff1a; 一台多多台机器&#xff0c;操作系统CentOS.x-86_x…

数据结构——栈(顺序结构)

一、栈的定义 栈是一种数据结构&#xff0c;它是一种只能在一端进行插入和删除操作的特殊线性表。这一端被称为栈顶&#xff0c;另一端被称为栈底。栈按照后进先出&#xff08;LIFO&#xff09;的原则进行操作&#xff08;类似与手枪装弹后射出子弹的顺序&#xff09;。在计算…