lv5 嵌入式开发-7 有名管道和无名管道

目录

1 进程间通信介绍

2 无名管道

2.1 无名管道特点 

​编辑

2.2 读无名管道

2.3 写无名管道

3 有名管道

3.1 有名管道特点

3.2 写有名管道 

 3.3 读有名管道

掌握：进程间通信方式介绍、无名管道特点、无名管道创建、无名管道读写特性；有名管道特点、有名管道创建、有名管道读写

1 进程间通信介绍

无名管道（pipe）

有名管道 （fifo）

信号（signal）

共享内存(mmap)

套接字（socket）  开销较大，但是常用

System V IPC                             不需要过度关注

共享内存（share memory）       不需要过度关注

消息队列（message queue）     不需要过度关注

信号灯集（semaphore set）       不需要过度关注

2 无名管道

2.1 无名管道特点 

  • 只能用于具有亲缘关系的进程之间的通信（父与子、兄弟）
  • 单工的通信模式，具有固定的读端和写端（需要双工则创建2个管道）
  • 无名管道创建时会返回两个文件描述符，分别用于读写管道

无名管道创建 – pipe

#include  <unistd.h>
int  pipe(int pfd[2]);
  • 成功时返回0，失败时返回EOF  
  • pfd  包含两个元素的整形数组，用来保存文件描述符  
  • pfd[0]用于读管道；pfd[1]用于写管道

无名管道通信

示例:

#include <stdio.h>
#include <unistd.h>
#include <string.h>
int main(){int pfd[2];int re;char buf[20]={0};pid_t pid;re = pipe(pfd);if(re<0){perror("pipe");return 0;}printf("%d,%d\n",pfd[0],pfd[1]);//因为是无名管道是亲缘关系间通信，所以使用fork创建一个子进程pid = fork();if(pid<0){perror("fork");return 0;}else if(pid>0){//close(pfd[0]);  //父写while(1){strcpy(buf,"hhahahahah");write(pfd[1],buf,strlen(buf));sleep(1);}}else{//close(pfd[1]);   //子读  while(1){re=read(pfd[0],buf,20);if(re>0){printf("read pipe=%s\n",buf);}    }}}
//运行结果

示例2：2个子进程写，一个父进程读

 

#include <stdio.h>
#include <unistd.h>
#include <string.h>
int main(){int pfd[2];int i;int re;char buf[40]={0};pid_t pid;re = pipe(pfd);if(re<0){perror("pipe");return 0;}printf("%d,%d\n",pfd[0],pfd[1]);for(i=0;i<2;i++){pid = fork();if(pid<0){perror("fork");return 0;}else if(pid>0){}else{break;   }}if(i==2){close(pfd[1]);while(1){memset(buf,0,40);re=read(pfd[0],buf,40);if(re>0){printf("%s\n",buf);}    }return 0;}if(i==1){close(pfd[0]);while(1){strcpy(buf,"this is 2 process");write(pfd[1],buf,strlen(buf));usleep(930000);  //如果同时写，读会有一些字符串重叠乱码}return 0;}if(i==0){close(pfd[0]);while(1){strcpy(buf,"this is 1 process");write(pfd[1],buf,strlen(buf));sleep(1);}return 0;}}

重点理解i = 2 是父进程，通过fork的返回值区分父进程和子进程

 

无名管道注意事项：

  • 只能用于亲缘关系的进程间通信（父子进程，兄弟进程）
  • 管道通信是单工的，一端读，一端写（程序实现设计好）。
  • 数据自己读不能自己写
  • 管道可以用于大于2个进程共享

2.2 读无名管道

读管道：

-管道中有数据，read返回实际读到的字节数。

-管道中无数据：

        管道写端被全部关闭，read返回0 (好像读到文件结尾)

        写端没有全部被关闭，read阻塞等待(不久的将来可能有数据递达，此时会让出cpu)

示例：写端关闭，读read=0

 不关闭也不写，阻塞

2.3 写无名管道

写管道：

-管道读端全部被关闭， 进程异常终止(也可使用捕捉SIGPIPE信号，使进程不终止)

-管道读端没有全部关闭：

        管道已满，write阻塞。（管道大小64K）

        管道未满，write将数据写入，并返回实际写入的字节数。

示例：

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
int main(){int pfd[2];int re;char buf[20]={0};pid_t pid;re = pipe(pfd);if(re<0){perror("pipe");return 0;}printf("%d,%d\n",pfd[0],pfd[1]);pid = fork();if(pid<0){perror("fork");return 0;}else if(pid>0){close(pfd[0]);
//        close(pfd[1]);int j=0;while(1){j++;strcpy(buf,"hhahahahah");for(int i=0;i<1000;i++){write(pfd[1],buf,strlen(buf));}printf("write %d times\n",j);sleep(1);}}else{close(pfd[1]); // close(pfd[0]);sleep(30000);exit(0);while(1){re=read(pfd[0],buf,20);if(re>0){printf("read pipe=%s\n",buf);}else if(re==0){printf("re=0\n");}}}}

如何获取无名管道的大小？

循环写入管道，直到阻塞

统计循环次数

读端不存在 有空间 无空间   管道断裂！  

如何验证管道断裂(进程被信号结束)？

子进程写管道

父进程回收

3 有名管道

3.1 有名管道特点

  • 有名管道特点
  • 有名管道可以使非亲缘的两个进程互相通信
  • 通过路径名来操作，在文件系统中可见，但内容存放在内存中  
  • 文件IO来操作有名管道
  • 遵循先进先出规则  
  • 不支持leek操作
  • 单工读写

有名管道创建 – mkfifo

#include  <unistd.h>
#include <fcntl.h>
int mkfifo(const char *path, mode_t mode);
  • 成功时返回0，失败时返回EOF  
  • path  创建的管道文件路径  
  • mode 管道文件的权限，如0666

有名管道读写 – 示例

进程A：循环从键盘输入并写入有名管道myfifo，输入quit时退出

进程B：循环统计进程A每次写入myfifo的字符串的长度

有个管道的打开

open(const char *path, O_RDONLY);//1
open(const char *path, O_RDONLY | O_NONBLOCK);//2
open(const char *path, O_WRONLY);//3
open(const char *path, O_WRONLY | O_NONBLOCK);//4

3.2 写有名管道 

示例：注意不要创建在windows与linux的共享目录，因为win不支持

#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>int main(){int re;int fd;char buf[32];re = mkfifo("/myfifo",0666);if(re<0){perror("mkfifo");//return 0;}fd = open("/myfifo",O_WRONLY|O_NONBLOCK);if(fd<0){perror("open");return 0;}printf("after open\n");while(1){fgets(buf,32,stdin);write(fd,buf,strlen(buf));}
}

 3.3 读有名管道

#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>int main(){int re;int fd;char buf[32];
/*re = mkfifo("/myfifo",0666);if(re<0){perror("mkfifo");return 0;}*/fd = open("/myfifo",O_RDONLY);if(fd<0){perror("open");return 0;}printf("after open\n");while(1){re=read(fd,buf,32);if(re>0){printf("read fifo=%s\n",buf);}else if(re==0){  //写退出，读程序的处理exit(0);}}
}

读写效果：写终端操作输入，另一终端输出

 

/*  create_fifo.c  */
// 省略头文件
int main(void) 
{if(mkfifo(“myfifo”, 0666) < 0) {perror(“mkfifo”);exit(-1);}return 0;
}

注意事项：

  1. 1 就是程序不能以O_RDWR(读写)模式打开FIFO文件进行读写操作，而其行为也未明确定义，因为如一个管道以读/写方式打开，进程可以读回自己的输出，同时我们通常使用FIFO只是为了单向的数据传递

2 第二个参数中的选项O_NONBLOCK，选项O_NONBLOCK表示非阻塞，加上这个选项后，表示open调用是非阻塞的，如果没有这个选项，则表示open调用是阻塞的。

3  对于以只读方式（O_RDONLY）打开的FIFO文件，如果open调用是阻塞的（即第二个参数为O_RDONLY），除非有一个进程以写方式打开同一个FIFO，否则它不会返回；如果open调用是非阻塞的的（即第二个参数为O_RDONLY | O_NONBLOCK），则即使没有其他进程以写方式打开同一个FIFO文件，open调用将成功并立即返回。

4 对于以只写方式（O_WRONLY）打开的FIFO文件，如果open调用是阻塞的（即第二个参数为O_WRONLY），open调用将被阻塞，直到有一个进程以只读方式打开同一个FIFO文件为止；如果open调用是非阻塞的（即第二个参数为O_WRONLY | O_NONBLOCK），open总会立即返回，但如果没有其他进程以只读方式打开同一个FIFO文件，open调用将返回-1，并且FIFO也不会被打开。

5 数据完整性,如果有多个进程写同一个管道，使用O_WRONLY方式打开管道，如果写入的数据长度小于等于PIPE_BUF（4K），那么或者写入全部字节，或者一个字节都不写入，系统就可以确保数据决不会交错在一起。

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

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

相关文章

深入浅出DAX：SELECTEDVALUE()

深入浅出DAX：SELECTEDVALUE()

深入浅出DAX&#xff1a;SELECTEDVALUE() SELECTEDVALUE()&#xff0c;如果筛选 columnName 的上下文后仅剩下一个非重复值&#xff0c;则返回该值。否则返回alternateResult&#xff0c;语法如下&#xff1a; SELECTEDVALUE(<columnName>[, <alternateResult>] …
阅读更多...
Rabbit消息的可靠性

Rabbit消息的可靠性

生产者重连 消费者重试 Confirm模式简介 消息的confirm确认机制&#xff0c;是指生产者投递消息后&#xff0c;到达了消息服务器Broker里面的exchange交换机&#xff0c;则会给生产者一个应答&#xff0c;生产者接收到应答&#xff0c;用来确定这条消息是否正常的发送到Broker…
阅读更多...
【大数据】Doris 构建实时数仓落地方案详解（三）：Doris 实时数仓设计

【大数据】Doris 构建实时数仓落地方案详解（三）：Doris 实时数仓设计

本系列包含&#xff1a; Doris 构建实时数仓落地方案详解&#xff08;一&#xff09;&#xff1a;实时数据仓库概述Doris 构建实时数仓落地方案详解&#xff08;二&#xff09;&#xff1a;Doris 核心功能解读Doris 构建实时数仓落地方案详解&#xff08;三&#xff09;&#…
阅读更多...
数据库存储引擎和数据类型详细介绍

数据库存储引擎和数据类型详细介绍

目录 一、数据库存储引擎&#xff08;了解&#xff09;1.了解MySQL体系结构2.存储引擎&#xff08;了解&#xff09;2.1.存储引擎的介绍2.2.存储引擎分类2.3.如何选择引擎&#xff1f; 3.事务控制语言(TCL)事务的四个特性(ACID) 二、数据类型&#xff08;了解&#xff09;1.整型…
阅读更多...
Servlet操作与用法（保姆式教学）

Servlet操作与用法（保姆式教学）

Servlet介绍 什么是servlet Servlet&#xff08;Servlet Applet的缩写&#xff0c;全称 Java Servlet&#xff09;&#xff1a;适用于Java编写的服务器程序&#xff0c;其主要功能是在于交互式的浏览和修改数据&#xff0c;生成动态Web内容。狭义的Servlet是指Java语言实现的…
阅读更多...
Xmake v2.8.3 发布，改进 Wasm 并支持 Xmake 源码调试

Xmake v2.8.3 发布，改进 Wasm 并支持 Xmake 源码调试

Xmake 是一个基于 Lua 的轻量级跨平台构建工具。 它非常的轻量&#xff0c;没有任何依赖&#xff0c;因为它内置了 Lua 运行时。 它使用 xmake.lua 维护项目构建&#xff0c;相比 makefile/CMakeLists.txt&#xff0c;配置语法更加简洁直观&#xff0c;对新手非常友好&#x…
阅读更多...
ARM day1

ARM day1

1.复习今日内容 2.搭建汇编环境 下发资料-》工具软件 -》汇编环境搭建 3.安装Ubuntu下的交叉编译工具链 思维导图&#xff1a;
阅读更多...
latexocr安装过程中遇到的问题解决办法

latexocr安装过程中遇到的问题解决办法

环境要求&#xff1a;需要Python版本3.7&#xff0c;并安装相应依赖文件 具体的详细安装步骤可见我上次写的博文&#xff1a;Mathpix替代者|科研人必备公式识别插件|latexocr安装教程 ‘latexocr‘ 不是内部或外部命令&#xff0c;也不是可运行的程序或批处理文件的相关解决办…
阅读更多...
十五、异常（2）

十五、异常（2）

本章概要 自定义异常 异常与记录日志 异常声明 自定义异常 不必拘泥于 Java 已有的异常类型。Java异常体系不可能预见你将报告的所有错误&#xff0c;所以你可以创建自己的异常类&#xff0c;来表示你的程序中可能遇到的问题。 要自己定义异常类&#xff0c;必须从已有的异…
阅读更多...
什么是 Redis?

什么是 Redis?

Redis 是一种基于内存的数据库&#xff0c;对数据的读写操作都是在内存中完成的&#xff0c;因此读写速度非常快&#xff0c;常用于缓存&#xff0c;消息队列&#xff0c;分布式锁等场景。 Redis 提供了多种数据类型来支持不同的业务场景&#xff0c;比如 String(字符串)、Has…
阅读更多...
C语言环境搭建(Win)

C语言环境搭建(Win)

一、C语言简介 1、 C语言简介 C语言是一门通用的、面向过程式的编译型语言&#xff0c;它的运行速度极快&#xff0c;仅次于汇编语言。 C语言是计算机产业的核心程序设计语言&#xff0c;操作系统、硬件驱动、关键组件、数据库等都离不开C语言&#xff0c;广泛应用于底层开发。…
阅读更多...
CompletableFuture-链式语法和join方法介绍

CompletableFuture-链式语法和join方法介绍

2.4 案例精讲-从电商网站的比价需求展开 2.4.1 函数式编程已成为主流 Lambda表达式Stream流式调用Chain链式调用Java8函数式编程 函数式接口&#xff1a; 小结&#xff1a; 函数式接口&#xff1a; Java8新特性_四大内置核心函数式接口_java8 内置核心接口_ZHOU_VIP的博客-…
阅读更多...
Nginx之memcached_module模块解读

Nginx之memcached_module模块解读

目录 基本介绍 安装添加模块 模块配置指令 基本介绍 nginx的memcached_module模块可以直接从memcached服务器中读取内容后输出&#xff0c;后续的请求不再经过应用程序处理&#xff0c;如php-fpm、django&#xff0c;大大的提升动态页面的速度。nginx只负责从memcach…
阅读更多...
学习路之PHP--lumen安装配置

学习路之PHP--lumen安装配置

一、下载lumen源码 composer create-project --prefer-dist laravel/lumen blog 安装lumen-generator composer require flipbox/lumen-generator 二、配置 bootstrap\app.php 97行 $app->register(Flipbox\LumenGenerator\LumenGeneratorServiceProvider::class);三、生成…
阅读更多...
【IDEA】IDEA 单行注释开头添加空格

【IDEA】IDEA 单行注释开头添加空格

操作 打开 IDEA 的 Settings 对话框&#xff08;快捷键为CtrlAltS&#xff09;&#xff1b;在左侧面板中选择Editor -> Code Style -> Java&#xff1b;在右侧面板中选择Code Generation选项卡&#xff1b;将Line comment at first column选项设置为false使注释加在行开…
阅读更多...
ICCV 2023|Occ2Net，一种基于3D 占据估计的有效且稳健的带有遮挡区域的图像匹配方法...

ICCV 2023|Occ2Net，一种基于3D 占据估计的有效且稳健的带有遮挡区域的图像匹配方法...

本文为大家介绍一篇入选ICCV 2023的论文&#xff0c;《Occ2Net: Robust Image Matching Based on 3D Occupancy Estimation for Occluded Regions》&#xff0c; 一种基于3D 占据估计的有效且稳健的带有遮挡区域的图像匹配方法。 论文链接&#xff1a;https://arxiv.org/abs/23…
阅读更多...
学生宿舍管理系统（前端java+后端Vue）实现-含前端与后端程序

学生宿舍管理系统（前端java+后端Vue）实现-含前端与后端程序

界面介绍 登录 ###宿舍管理 ###菜单管理 ###角色管理 ###班级管理
阅读更多...
TensorFlow入门(五、指定GPU运算)

TensorFlow入门(五、指定GPU运算)

一般情况下,下载的TensorFlow版本如果是GPU版本,在运行过程中TensorFlow能自动检测。如果检测到GPU,TensorFlow会默认利用找到的第一个GPU来执行操作。如果机器上有超过一个可用的GPU,除第一个之外的其他GPU默认是不参与计算的。如果想让TensorFlow使用这些GPU执行操作,需要将运…
阅读更多...
源码：TMS FlexCel Studio for .NET 7.19

源码：TMS FlexCel Studio for .NET 7.19

TMS FlexCel Studio for .NET 是100% 托管代码 Excel 文件操作引擎以及 Excel 和 PDF 报告生成&#xff0c;适用于 .NET、Xamarin.iOS、Xamarin.Android、Xamarin.Mac、Windows Phone 和 Windows Store 功能概述 使用 FlexCel Studio for .NET 创建可动态快速读写 Excel 文件的…
阅读更多...
多线程(虚拟地址空间)

多线程(虚拟地址空间)

代码展示线程 既然我们提到了&#xff0c;线程隶属于进程&#xff0c;是进程的一个执行分支 真的是这样吗&#xff1f; 我们还需要用代码来验证 初步思路是创建三个线程&#xff0c;其中main函数里面的为主线程 不断循环&#xff0c;并且打印相应的pid 假如它们属于不同的进程…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023