哪个网站平面设计做的好/世界500强企业

哪个网站平面设计做的好,世界500强企业,全响应网站制作,深圳做响应式网站制作进程间通信介绍 进程间通信目的 数据传输：一个进程需要将它的数据发送给另一个进程资源共享：多个进程之间共享同样的资源。通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件&…

进程间通信介绍

 进程间通信目的

  • 数据传输：一个进程需要将它的数据发送给另一个进程
  • 资源共享：多个进程之间共享同样的资源。
  • 通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件（如进程终止时要通知父进程）。
  • 进程控制：有些进程希望完全控制另一个进程的执行（如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，一经查实，立即删除！

相关文章

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

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

一、块元素&#xff08;Block Elements&#xff09; 1.定义与特点 独占一行&#xff1a;默认情况下&#xff0c;块元素会从新的一行开始&#xff0c;并且其后的元素也会被推到下一行。可设置宽高&#xff1a;可以自由设置宽度&#xff08;width&#xff09;和高度&#xff08…
阅读更多...
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;体现的…
阅读更多...
力扣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;并且都开启防…
阅读更多...
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…
阅读更多...
推理大模型的后训练增强技术-Reasoning模型也进化到2.0了，这次居然学会用工具了

推理大模型的后训练增强技术-Reasoning模型也进化到2.0了，这次居然学会用工具了

论文题目&#xff1a;START: Self-taught Reasoner with Tools 论文链接&#xff1a;https://arxiv.org/pdf/2503.04625 论文简介 Reasoning模型也进化到2.0了&#xff0c;这次居然学会用工具了&#xff01;✨ 最近有个叫START的方法&#xff0c;让大模型也能学着用工具&#…
阅读更多...
基于llama.cpp的QwQ32B模型推理

基于llama.cpp的QwQ32B模型推理

基于llama.cpp的QwQ32B模型推理 llama.cpp项目主页&#xff1a; https://github.com/ggml-org/llama.cpp# llama.cpp源码下载 cd /root/lanyun-tmpgit clone https://github.com/ggml-org/llama.cpp#llama.cpp编译 llama.cpp是个C语言项目&#xff0c;实际调用过程需要先构建项…
阅读更多...
如何使用Spring AI提示词模板PromptTemplate？

如何使用Spring AI提示词模板PromptTemplate？

如何使用Spring AI提示词模板PromptTemplate 目录 如何使用Spring AI提示词模板PromptTemplate 1、提示词Prompt介绍 2、Spring Boot集成Spring AI框架 3、提示词模板PromptTemplate用法 4、开发代码使用PromptTemplate 5、启动Springboot工程并验证 本文章节介绍Prompt…
阅读更多...
Windows Server中的NTP服务器部署（NTP Srver Deployment in Windows Server）

Windows Server中的NTP服务器部署（NTP Srver Deployment in Windows Server）

构建稳定内网时间同步&#xff1a;Windows Server中的NTP服务器部署指南 服务简介 NTP&#xff08;Network Time Protocol&#xff09;服务器是用于同步计算机网络中各设备时间的服务器。它通过网络协议与标准时间源&#xff08;如原子钟、GPS系统等&#xff09;进行时间同步&…
阅读更多...
【 ＜二＞ 丹方改良：Spring 时代的 JavaWeb】之 Spring Boot 的自动配置：约定优于配置的设计美学

【 ＜二＞ 丹方改良：Spring 时代的 JavaWeb】之 Spring Boot 的自动配置：约定优于配置的设计美学

<前文回顾> 点击此处查看 合集 https://blog.csdn.net/foyodesigner/category_12907601.html?fromshareblogcolumn&sharetypeblogcolumn&sharerId12907601&sharereferPC&sharesourceFoyoDesigner&sharefromfrom_link <今日更新> 一、Spring…
阅读更多...
SourceTree的安装与使用

SourceTree的安装与使用

SourceTree的安装与使用 一、前言 作为可视化Git管理工具&#xff0c;SourceTree可以避免我们使用命令进行常规的代码拉取&#xff0c;更新&#xff0c;合并等操作。 鼠标点点就可以完成代码管理的工作。所以强烈推荐可视化的工具。不过SourceTree还是有点bug&#xff0c;比…
阅读更多...
JMeter 性能测试

JMeter 性能测试

Jmeter 用户手册 名词解释&#xff1a; RPS&#xff1a;每秒请求数-每秒向服务器发送多少请求数&#xff08;一个场景&#xff0c;系统面临多大的压力&#xff09; TPS&#xff1a;每秒事务数-每秒能够处理多少请求/事务数性能评价标准&#xff08;其中的一个核心指标&#x…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023