进程间通信--匿名管道

进程间通信介绍

 进程间通信目的

  • 数据传输：一个进程需要将它的数据发送给另一个进程
  • 资源共享：多个进程之间共享同样的资源。
  • 通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件（如进程终止时要通知父进程）。
  • 进程控制：有些进程希望完全控制另一个进程的执行（如Debug进程），此时控制进程希望能够拦截另一个进程的所有陷入和异常，并能够及时知道它的状态改变。

 管道


什么是管道
管道是Unix中最古老的进程间通信的形式。我们把从一个进程连接到另一个进程的一个数据流称为一个“管道”如：

 用fork来共享管道原理

 站在文件描述符角度-深度理解管道 （内存级）

 左边是进程管理，右边是文件管理，进程通过全局变量能找到文件描述符标，也就找到了对应的file文件也能打开磁盘上的文件拷贝到缓冲区里进行读写，父进程创建子进程，发生写实拷贝，类似于浅拷贝，此时不做文件操作，文件描述符里面的对于关系和父进程一样，struc_file没有关闭，因为父进程还在， struc_file的对应的引用计数不为0就一定不会关闭，既然访问的同一个struc_file，也可以同时访问其中的file文件，通过缓冲区可以进行文件的读写

  1. 父进程通过读写两种方式打开内存级的文件返回给上层完成管道的创建
  2. 子进程继承父进程的文件描述符表，发生浅拷贝，也能拿到父进程以读写打开的管道文件
  3. 父子都看得到，让父子单向通信，父进程写，子进程读，各自关闭掉自己不需要的文件描述符

这个是管道是OS单独设计的，得配上单独的系统调用：pipe 内存级的，不需要文件路径，没有文件名，所以叫匿名管道，那我们怎么保证，两个进程打开的是同一个管道的？

子进程继承了父进程的文件描述符表

站在内核角度-管道本质

 匿名管道

#include <unistd.h>
功能:创建⼀⽆名管道
原型
int pipe(int fd[2]);
参数
fd：⽂件描述符数组,其中fd[0]表⽰读端, fd[1]表⽰写端
返回值:成功返回0，失败返回错误代码
#include<iostream>
#include<unistd.h>
using namespace std;
int main()
{int fds[2]={0};int n=pipe(fds);if(n<0){cerr<<"Pipe error"<<endl;return 1;}cout<<"fds[0]"<<fds[0]<<endl;cout<<"fds[1]"<<fds[1]<<endl;return 0;
}

0，1，2被三个标准占用了，从3，4开始

父写子读，实现通信

#include<iostream>
#include<unistd.h>
#include<sys/wait.h>
#include<sys/types.h>
#include<cstring>
using namespace std;void ChildWrite(int fd)
{
char buffer[1024];
int cnt=0;
while(true)
{
snprintf(buffer,sizeof(buffer),"I am child,pid:%d cnt:%d\n",getpid(),cnt++); 
write(fd,buffer,strlen(buffer));
sleep(1);
}
}
void FatherRead(int fd)
{char buffer[1024];while(true){buffer[0]=0;ssize_t n=read(fd,buffer,sizeof(buffer)-1);if(n>0){buffer[n]=0;cout<<"child says: "<<buffer<<endl;}}
}
int main()
{  //1.创建管道int fds[2]={0}; //fds[0]读端，fds[1]写端int n=pipe(fds);if(n<0){cerr<<"Pipe error"<<endl;return 1;}cout<<"fds[0]"<<fds[0]<<endl;cout<<"fds[1]"<<fds[1]<<endl;//3.创建子进程 f->r c->wpid_t id=fork();if(id==0){//childclose(fds[0]); //关闭读端ChildWrite(fds[1]);close(fds[1]);exit(0);}
close(fds[1]); //关闭写端
FatherRead(fds[0]);
waitpid(id,nullptr,0);
close(fds[0]);return 0;
}

父进程写的cnt在不断变化，子进程能读到，说明实现了管道通信

五种特性

1.匿名管道，只能用来进行具有血缘关系的进程进行进程间通信(常用父与子，如上述代码)

2.管道文件，自带同步机制（父子进程进行IO同时进行，一个读一个写，不管是父快还是子快，父不断写，子read读不到会阻塞住直到读到为止）

3.管道是面向字节流的

4.管道是单向通信的（要么父写子读，要么子写父读）

5. （管道）文件的生命周期随进程

4种通信情况 

1.写慢，读快------>读端阻塞等待写端(进程)

2.写快，读慢------>缓冲区写满了，写要阻塞等待读端

3.写关，读开------>read会读到返回值0，表示文件结尾

//写一条就关
void ChildWrite(int fd)
{
char buffer[1024];
int cnt=0;
while(true)
{
snprintf(buffer,sizeof(buffer),"I am child,pid:%d cnt:%d\n",getpid(),cnt++); 
write(fd,buffer,strlen(buffer));
sleep(1);
break;
}
}
//观察n的返回值
void FatherRead(int fd)
{char buffer[1024];while(true){buffer[0]=0;ssize_t n=read(fd,buffer,sizeof(buffer)-1);if(n>0){buffer[n]=0;cout<<"child says: "<<buffer<<endl;}else{cout<< "n:"<<n<<endl;}}
}

 4.读关，写开------->写端再写没有意义，OS会杀掉写端进程

#include<iostream>
#include<unistd.h>
#include<sys/wait.h>
#include<sys/types.h>
#include<cstring>
using namespace std;void ChildWrite(int fd)
{
char buffer[1024];
int cnt=0;
while(true)
{
snprintf(buffer,sizeof(buffer),"I am child,pid:%d cnt:%d\n",getpid(),cnt++); 
write(fd,buffer,strlen(buffer));
sleep(1);
}
}
void FatherRead(int fd)
{char buffer[1024];while(true){buffer[0]=0;ssize_t n=read(fd,buffer,sizeof(buffer)-1);if(n>0){buffer[n]=0;cout<<"child says: "<<buffer<<endl;}else{cout<< "n:"<<n<<endl;sleep(4);}break;}
}
int main()
{  //1.创建管道int fds[2]={0}; //fds[0]读端，fds[1]写端int n=pipe(fds);if(n<0){cerr<<"Pipe error"<<endl;return 1;} cout<<"fds[0]"<<fds[0]<<endl;cout<<"fds[1]"<<fds[1]<<endl;//3.创建子进程 f->r c->wpid_t id=fork();if(id==0){//childclose(fds[0]); //关闭读端ChildWrite(fds[1]);close(fds[1]);exit(0);}
close(fds[1]); //关闭写端
FatherRead(fds[0]);
close(fds[0]);int status;
int ret=waitpid(id,&status,0);
//获取到子进程的退出状态
if(ret>0)
{printf("child code: %d exited  status: %d\n",(status)>>8&0xff,(status)&0x7f);
}
return 0;
}

发送异常信号13 SIGPIPE 

 基于匿名管道----进程池

父进程创建多个子进程，用匿名管道分派任务

 1.构建进程链，为进程池做准备

#ifndef __PROCESS__POOL_HPP__
#define __PROCESS__POOL_HPP__
#include <iostream>
#include <vector>
#include <unistd.h>
#include<cstdlib>
using namespace std;
const int gdefaultnum = 5; // 要创建几个进程
// 先描述 单个进程
class Channel
{
public:Channel() {}~Channel() {}private:int _wfd;
};// 在组织  进程链
class ChannelManager
{
public:ChannelManager() {}~ChannelManager() {}private:vector<Channel> _channels;
};

 2.创建进程池，提供管道条件

// 进程池
class ProcessPool
{
public:ProcessPool(int num) : _process_num(num) {}~ProcessPool() {}bool Create(){int pipefd[2] = {0};for (int i = 0; i < _process_num; i++){// 1.创建管道int n = pipe(pipefd);if (n < 0)return false;}// 2.创建子进程  各自关闭不需要的文件描述符pid_t id = fork();if (id < 0)return false;else if (id == 0){// 子进程 --->读// 3.关闭不需要的文件描述符close(pipefd[1]);exit(0);}else{// 父进程 --->写// 3.关闭不需要的文件描述符close(pipefd[0]);}return true;}private:ChannelManager _cm; // 进程链int _process_num;   // 进程个数
};

3.父子各自打印验证是否通信

void BuildChannel(int wfd, pid_t subid){_channels.emplace_back(wfd, subid);// Channel c(wfd,subid);// _channels.push_back(c);}void Print()
{for(auto  &chnnel : _channels){
cout<<chnnel.Name()<<endl;}
}void Work(int rfd){while (true){cout << "我是子进程，我的rfd是：" << rfd << endl;sleep(2);}}
//ProcessPool.hpp
#ifndef __PROCESS__POOL_HPP__
#define __PROCESS__POOL_HPP__
#include <iostream>
#include <vector>
#include <unistd.h>
#include <cstdlib>
using namespace std;
const int gdefaultnum = 5; // 要创建几个进程
// 先描述 单个进程
class Channel
{
public:Channel(int fd, pid_t id) : _wfd(fd), _subid(id) { _name = "chnnel-" + std::to_string(_wfd) + "-" + std::to_string(_subid); }~Channel() {}int Fd(){return  _wfd;}pid_t Subid(){return  _subid;}string Name(){return  _name;}
private:int _wfd;pid_t _subid;std::string _name;
};// 在组织  进程链
class ChannelManager
{
public:ChannelManager() {}~ChannelManager() {}void BuildChannel(int wfd, pid_t subid){_channels.emplace_back(wfd, subid);// Channel c(wfd,subid);// _channels.push_back(c);}void Print()
{for(auto  &chnnel : _channels){
cout<<chnnel.Name()<<endl;}
}
private:vector<Channel> _channels;
};// 进程池
class ProcessPool
{
public:ProcessPool(int num) : _process_num(num) {}~ProcessPool() {}void Work(int rfd){while (true){cout << "我是子进程，我的rfd是：" << rfd << endl;sleep(2);}}bool Create(){for (int i = 0; i < _process_num; i++){int pipefd[2] = {0};// 1.创建管道int n = pipe(pipefd);if (n < 0)return false;// 2.创建子进程  父子各自关闭不需要的文件描述符pid_t id = fork();if (id < 0)return false;else if (id == 0){// 子进程 --->读// 3.关闭不需要的文件描述符close(pipefd[1]);Work(pipefd[0]);exit(0);}else{// 父进程 --->写// 3.关闭不需要的文件描述符close(pipefd[0]);_cm.BuildChannel(pipefd[1], id);close(pipefd[1]);}}return true;}void Debug(){_cm.Print();}
private:ChannelManager _cm; // 进程链int _process_num;   // 进程个数
};#endif
//Main.cc#include"ProcessPool.hpp"int main()
{ProcessPool pp(gdefaultnum);//创建进程池pp.Create();//打印进程池pp.Debug();sleep(1000);return 0;
}

实现通信 

 4.分配任务，子写父读

 void Work(int rfd){while (true){int code = 0;ssize_t n = read(rfd, &code, sizeof(code));if (n > 0){if (n == sizeof(code)){continue;}cout << "子进程[]"<<getpid()<<"]收到一个任务码:" << code << endl;}else if (n == 0){cout << "子进程退出" << endl;break;}else{// 读失败cout << "读取错误" << endl;break;}}}void PushTack(int taskcode){// 1.选择一个子进程，采用轮询，防止负载均衡和负载不均衡auto &c = _cm.Select();cout << "选择一个子进程：" << c.Name() << endl;// 2.发送任务c.Send(taskcode);cout << "发送了一个任务码：" << taskcode << endl;}

完整代码

//ProcessPool.hpp
#ifndef __PROCESS__POOL_HPP__
#define __PROCESS__POOL_HPP__
#include <iostream>
#include <vector>
#include <unistd.h>
#include <cstdlib>
using namespace std;
const int gdefaultnum = 5; // 要创建几个进程
// 先描述 单个进程
class Channel
{
public:Channel(int fd, pid_t id) : _wfd(fd), _subid(id) { _name = "chnnel-" + std::to_string(_wfd) + "-" + std::to_string(_subid); }~Channel() {}int Fd() { return _wfd; }pid_t Subid() { return _subid; }string Name() { return _name; }void Send(int code){int n = write(_wfd, &code, sizeof(code));(void)n;}private:int _wfd;pid_t _subid;std::string _name;
};// 在组织  进程链
class ChannelManager
{
public:ChannelManager() : _next(0) {}~ChannelManager() {}void BuildChannel(int wfd, pid_t subid){_channels.emplace_back(wfd, subid);// Channel c(wfd,subid);// _channels.push_back(c);}// 轮询Channel &Select(){auto &c = _channels[_next];_next++;_next %= _channels.size();return c;}void Print(){for (auto &chnnel : _channels){cout << chnnel.Name() << endl;}}private:vector<Channel> _channels;int _next;
};// 进程池
class ProcessPool
{
public:ProcessPool(int num) : _process_num(num) {}~ProcessPool() {}void Work(int rfd){while (true){int code = 0;ssize_t n = read(rfd, &code, sizeof(code));if (n > 0){if (n == sizeof(code)){continue;}cout << "子进程[]"<<getpid()<<"]收到一个任务码:" << code << endl;}else if (n == 0){cout << "子进程退出" << endl;break;}else{// 读失败cout << "读取错误" << endl;break;}}}bool Create(){for (int i = 0; i < _process_num; i++){int pipefd[2] = {0};// 1.创建管道int n = pipe(pipefd);if (n < 0)return false;// 2.创建子进程  父子各自关闭不需要的文件描述符pid_t id = fork();if (id < 0)return false;else if (id == 0){// 子进程 --->读// 3.关闭不需要的文件描述符close(pipefd[1]);Work(pipefd[0]);exit(0);}else{// 父进程 --->写// 3.关闭不需要的文件描述符close(pipefd[0]);_cm.BuildChannel(pipefd[1], id);close(pipefd[1]);}}return true;}void Debug(){_cm.Print();}void PushTack(int taskcode){// 1.选择一个子进程，采用轮询，防止负载均衡和负载不均衡auto &c = _cm.Select();cout << "选择一个子进程：" << c.Name() << endl;// 2.发送任务c.Send(taskcode);cout << "发送了一个任务码：" << taskcode << endl;}private:ChannelManager _cm; // 进程链int _process_num;   // 进程个数
};#endif
//Main.cc#include"ProcessPool.hpp"int main()
{ProcessPool pp(gdefaultnum);//创建进程池pp.Create();//打印进程池//pp.Debug();int task_code = 1;while(true){pp.PushTack(task_code++);sleep(1);}return 0;
}

创建进程池后，OS关闭了没有意义的管道，每次选择一个管道接受消息 

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

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

相关文章

vue computed 计算属性简述

vue computed 计算属性简述

Vue 的 ‌计算属性&#xff08;Computed Properties&#xff09;‌ 是 Vue 实例中一种特殊的属性&#xff0c;用于‌声明式地定义依赖其他数据动态计算得出的值‌。它的核心优势在于能够自动追踪依赖关系&#xff0c;并缓存计算结果&#xff0c;避免重复计算&#xff0c;提升性…
阅读更多...
CSS块元素、行内元素、行内块元素详解

CSS块元素、行内元素、行内块元素详解

一、块元素&#xff08;Block Elements&#xff09; 1.定义与特点 独占一行&#xff1a;默认情况下&#xff0c;块元素会从新的一行开始&#xff0c;并且其后的元素也会被推到下一行。可设置宽高&#xff1a;可以自由设置宽度&#xff08;width&#xff09;和高度&#xff08…
阅读更多...
Vue3项目中可以尝试封装那些组件

Vue3项目中可以尝试封装那些组件

在 Vue 3 项目中&#xff0c;组件的封装可以根据功能、复用性和业务需求进行划分。以下是一些常见的组件类型&#xff0c;适合封装为独立组件&#xff1a; 1. 基础 UI 组件 按钮 (Button) 封装不同样式、大小、状态的按钮。支持 disabled、loading 等状态。 输入框 (Input) 封…
阅读更多...
2025年AI搜索引擎开源项目全景指南：从核心框架到生态工具

2025年AI搜索引擎开源项目全景指南：从核心框架到生态工具

2025年AI搜索引擎开源项目全景指南&#xff1a;从核心框架到生态工具 在人工智能技术迅猛发展的当下&#xff0c;开源项目已成为构建AI搜索引擎的核心驱动力。本文整理9个具有代表性的开源项目&#xff0c;涵盖搜索框架、扩展生态及底层支持技术&#xff0c;助你快速搭建或优化…
阅读更多...
Word 小黑第22套

Word 小黑第22套

对应大猫23 续编号&#xff08;编号断了&#xff0c;从一开始&#xff09;&#xff1a;点编号&#xff0c;再设置编号值 插入以图标方式显示的文档&#xff1a;插入 -对象 -由文件创建 &#xff08;这里要链接到文件也要勾选 不然扣一分&#xff09; 一个页面设为横向不影响上…
阅读更多...
平面波扬声器 VS球面波扬声器的原理与优缺点对比

平面波扬声器 VS球面波扬声器的原理与优缺点对比

一、核心定义与原理 1、平面波扬声器 1.1、平面波扬声器的定义‌&#xff1a;通过“相控阵”技术控制声波相位&#xff0c;使声波以平行线&#xff08;面&#xff09;定向传播的扬声器&#xff0c;声波近似平面振动&#xff0c;能量集中且衰减缓慢‌。 1.2、平面波扬声器的原…
阅读更多...
设计模式之命令设计模式

设计模式之命令设计模式

命令设计模式&#xff08;Command Pattern&#xff09; 请求以命令的形式包裹在对象中&#xff0c;并传给调用对象。调用对象寻找可以处理该命令的对象&#xff0c;并把该命令传给相应的对象执行命令&#xff0c;属于行为型模式命令模式是一种特殊的策略模式&#xff0c;体现的…
阅读更多...
EcoVadis新增可持续发展徽章

EcoVadis新增可持续发展徽章

EcoVadis新增的两项新徽章旨在进一步激励和表彰企业在可持续发展方面的努力和成就。以下是这两项新徽章的概述&#xff1a; 可持续发展之旅徽章&#xff08;Sustainability Journey Badge&#xff09;&#xff1a; 目的&#xff1a;表彰那些在可持续发展方面展现出持续进步和承…
阅读更多...
力扣hot100二刷——二叉树

力扣hot100二刷——二叉树

第二次刷题不在idea写代码&#xff0c;而是直接在leetcode网站上写&#xff0c;“逼”自己掌握常用的函数。 标志掌握程度解释办法⭐Fully 完全掌握看到题目就有思路&#xff0c;编程也很流利⭐⭐Basically 基本掌握需要稍作思考&#xff0c;或者看到提示方法后能解答⭐⭐⭐Sl…
阅读更多...
从“自习室令牌”到线程同步：探秘锁与条件变量

从“自习室令牌”到线程同步：探秘锁与条件变量

目录 互斥 为什么需要锁 锁的原理--互斥 锁的使用 同步 锁的问题 条件变量 互斥 为什么需要锁 先看结果&#xff1a; 以下代码是我模拟创建线程抢票&#xff0c;由于不加锁导致票抢到了负数 main.cc: #include<vector> #include<iostream> #include"…
阅读更多...
字符串哈希从入门到精通

字符串哈希从入门到精通

一、基本概念 字符串哈希是将任意长度的字符串映射为固定长度的哈希值&#xff08;通常为整数&#xff09;的技术&#xff0c;核心目标是实现O(1)时间的子串快速比较和高效查询。其本质是通过数学运算将字符串转换为唯一性较高的数值&#xff0c;例如&#xff1a; ​​​​​​…
阅读更多...
什么是数学建模？数学建模是将实际问题转化为数学问题

什么是数学建模？数学建模是将实际问题转化为数学问题

数学建模是将实际问题转化为数学问题&#xff0c;并通过数学工具进行分析、求解和验证的过程。 一、数学建模的基本流程 问题分析 • 明确目标&#xff1a;确定需要解决的核心问题。 • 简化现实&#xff1a;识别关键变量、忽略次要因素。 • 定义输入和输出&#xff1a;明确模…
阅读更多...
搭建主从服务器

搭建主从服务器

任务需求 客户端通过访问 www.nihao.com 后&#xff0c;能够通过 dns 域名解析&#xff0c;访问到 nginx 服务中由 nfs 共享的首页文件&#xff0c;内容为&#xff1a;Very good, you have successfully set up the system. 各个主机能够实现时间同步&#xff0c;并且都开启防…
阅读更多...
【python web】一文掌握 Flask 的基础用法

【python web】一文掌握 Flask 的基础用法

文章目录 一、 Flask 介绍1.1 安装 Flask二、Flask的基本使用2.1 创建第一个 Flask 应用2.2 路由与视图函数2.3 请求与响应2.4 响应对象2.5 模板渲染2.6 模板继承2.7 静态文件管理2.8 Blueprint 蓝图2.9 错误处理三、Flask扩展与插件四、部署 Flask 应用五、总结Flask 是一个轻…
阅读更多...
最长最短单词（信息学奥赛一本通-1143）

最长最短单词（信息学奥赛一本通-1143）

【题目描述】 输入1行句子(不多于200个单词&#xff0c;每个单词长度不超过100)&#xff0c;只包含字母、空格和逗号。单词由至少一个连续的字母构成&#xff0c;空格和逗号都是单词间的间隔。 试输出第1个最长的单词和第1个最短单词。 【输入】 一行句子。 【输出】 第1行&…
阅读更多...
AlexNet 有哪些首创？

AlexNet 有哪些首创？

现在大家每逢讨论人工智能&#xff0c;都离不开深度学习&#xff0c;这轮深度学习的热潮&#xff0c;追根溯源可以到2012年 AlexNet 的横空出世。后来&#xff0c;大家开始发现深度学习越来越强的能力。 AlexNet 的首创贡献 AlexNet&#xff08;2012年&#xff09;作为现代深…
阅读更多...
【Linux我做主】基础命令完全指南上篇

【Linux我做主】基础命令完全指南上篇

Linux基础命令完全指南【上篇】 Linux基础命令完全指南github地址前言命令行操作的引入Linux文件系统树形结构的根文件系统绝对路径和相对路径适用场景Linux目录下的隐藏文件 基本指令目录和文件相关1. ls2. cd和pwdcdpwd 3. touch4. mkdir5. cp6. mv移动目录时覆盖写入的两种特…
阅读更多...
OceanBase 用户问题精选答疑：OceanBase 版本升级解析

OceanBase 用户问题精选答疑：OceanBase 版本升级解析

背景 此篇博客的源自于OceanBase社区论坛内一位名为皇甫侯的热心用户所提的建议&#xff0c;希望向OceanBase的用户介绍OceanBase的版本升级路径。本文以一个版本升级为示例&#xff0c;汇总了对用户而言比较重要的版本升级要点&#xff0c;期望通过这份分享&#xff0c;能让读…
阅读更多...
Docker Desktop 安装与使用详解

Docker Desktop 安装与使用详解

目录 1. 前言2. Docker Desktop 安装2.1 下载及安装2.2 登录 Docker 账号2.3 进入 Docker Desktop 主界面 3. Docker 版本查看与环境检查3.1 查看 Docker Desktop 支持的 Docker 和 Kubernetes 版本3.2 检查 Docker 版本 4. Docker Hub 和常用镜像管理方式4.1 使用 Docker Hub4…
阅读更多...
英文LaTeX中左右引号怎么打

英文LaTeX中左右引号怎么打

在英文 LaTeX 中&#xff0c;要输入左右引号&#xff0c;可以使用以下命令&#xff1a; 左双引号&#xff1a;&#xff08;两个反引号&#xff09;右双引号&#xff1a;&#xff08;两个单引号&#xff09; 例如&#xff1a; This is a quoted text.这将显示为&#xff1a; …
阅读更多...
最新文章

Copyright @ 2022~2023