linux之管道

管道(PIPE)是linux中一个重要的通信方式,在进程中,我们通过从一个进程中读取到的数据转到另一个进程中的写数据中,这时就要有不同的进程之间共享同一份资源,就是所谓的进程间通信。由于进程的特点是资源独占,所以我们就借助管道来实现。我们常说的管道多指无名管道,还有一种是命名管道(一次生成多个目标文件[FIFO])。下面分别讲解一下:

管道的特点:单向数据通信,有血缘关系的进程通信,生命周期(随进程的),同步与互斥

管道也是一种文件,它是以p开头的;

我们可以调用pipe()函数:int pipe(int fileds[2])来在内核中开辟一条缓冲区(即管道)来完成通信。它有一个读端一个写端,fileds[0]表示读端,fileds[1]表示写端。首先,由父进程创建管道;其次,由父进程创建子进程;最后,父进程关闭fd[0]读端,子进程关闭fd[1]写端,这样就使父进程往管道里写,子进程往管道里读,这样就实现了进程间通信。

然而通过管道实现父子进程之间的通信步骤是什么呢?




代码实现一下吧:



运行结果如下:


当子进程关闭读端,父进程关闭写端时,最后结果会每隔1s打印一个“i am a girl”;

一、对于管道来说我们通常有四种特殊情况需要考虑:

1.如果所有指向管道写端的文件描述符都关闭了(管道写端的引用计数等于0),而仍然有进程从管道的读端读数据,那

么管道中剩余的数据都被读取后,再次read会返回0,就像读到文件末尾一样。


运行结果:


2.如果有指向管道写端的文件描述符没关闭(管道写端的引用计数大于0),而持有管道写端的进程也没有向管道中写数据,这时有进程从管道读端读数据,那么管道中剩余的数 据都被读取后,再次read会阻塞,直到管道中有数据可读了才读取数据并返回。



运行结果:


此时,,会发现当运行完第十个i am a child之后,read端还想读取时,发生了堵塞。直到关闭写端后读端才退出不再读。

3.如果所有指向管道读端的文件描述符都关闭了(管道读端的引用计数等于0),这时有进程向管道的写端write,那么该进

程会收到信号SIGPIPE,通常会导致进程异常终止。 



运行结果:


此时,在子进程进行写了10个i am a child时,写完之后写端并没有关闭,当父进程读完三个i am a child之后,关闭读端,读端不再读,并且sleep了10秒。进程异常中止。

4.如果有指向管道读端的文件描述符没关闭(管道读端的引用计数大于0),而持有管道读端的进程也没有从管道中读数

据,这时有进程向管道写端写数据,那么在管道被写满时再次write会阻塞,直到管道中有空位置了才写入数据并返回。



运行结果:


此时,,写端一直在写,读端没有关闭,但却不读取数据,因此会导致write端阻塞,直到异常退出。


二、但是匿名管道只适用于具有血缘关系的进程之间通信。如果两个进程之间没有血缘关系的话怎么办呢?我们把没有血缘关系的进程之间的通信方式就可以通过命名管道来完成。创建命名管道的系统函数有:mknod和mkfifo。在这里,我们尽可能的使用mkfifo。命名管道也被称为FIFO文件,它是一种特殊类型的文件,它在文件系统中以文件名的形式存在;下面举一个两个不同进程之间进行通信的例子:

server.c为读端:



client.c为写端:


将两个不同的进程之间联系起来,当client.c写入数据时,打开另一个终端运行server.c,这样就会在server.c中显示出你输入的字符串,当遇到quit时,进程将结束。

另外,通过命令ulimit -a来看一下管道写入的最大大小为:


即:512*8 = 4kb;


以上就是管道的基本概念哦。微笑微笑

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

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

相关文章

把student a am i 变成 i am a student(两种方法)

文章目录#student a am i 变成 i am a student##方法1&#xff1a;指针#include <stdlib.h> #include <stdio.h> #include <string.h>void fanw(char *l, char *r) {char* left l;char* right r;char temp;while (left < right){temp *left;*left *ri…

关掉占用 某端口的进程

sudo fuser -k 8000/tcp 这样和端口8000相关的进程就都关了。

linux之多线程(1)

我们之前讲了进程&#xff0c;今天我们重新认识另外一个概念---线程。我们首先会想到的是进程和线程有什么区别和联系&#xff0c;对吧&#xff1f;进程是由程序执行起来&#xff0c;跑在操作系统的&#xff0c;是系统进行资源分配和调度的基本单位。进程具有资源独占性&#x…

C语言typedef与#define的区别

typedef和#define define 没有参加编译&#xff0c;在预处理的时候就被替换掉了。 typedef参加编译和链接。typedef是重命名&#xff0c;可以为枚举结构体等等重新命名&#xff0c;提高代码整洁。 一、typedef的用法 C语言中&#xff0c;typedef常用来定义一个标识符及关键…

django models模型 内部类 class Meta 简介

class Meta: #这个属性是定义当前的模型类是不是一个抽象类。所谓抽象类是不会相应数据库表的。一般我们用它来归纳一些公共属性字段&#xff0c;然后继承它的子类能够继承这些字段。abstractTrue #db_table是用于指定自己定义数据库表名的db_table test#因为Django的管理方法…

阻断血缘关系以及checkpoint文件清理

spark-sql读写同一张表&#xff0c;报错Cannot overwrite a path that is also being read from 1. 增加checkpoint&#xff0c;设置检查点阻断血缘关系 sparkSession.sparkContext.setCheckpointDir("/tmp/spark/job/OrderOnlineSparkJob")val oldOneIdTagSql s&…

linux之睡眠函数(my_sleep)

我们在程序中&#xff0c;很多次用到sleep()函数&#xff0c;让它睡眠几秒后再执行该进程。今天呢&#xff0c;我要给大家实现一下sleep函数。 看看代码哦&#xff1a; 运行结果&#xff1a; 结果中每隔三秒钟&#xff0c;打印一条语句。实现了sleep(3)的功能。 关于sleep函数…

C语言 防止头文件被多次引用

comm.h和comm.c是公共模块。 test1.h和test1.c使用了公共模块。 test2.h和test2.c使用了了公共模块。 test.h和test.c使⽤用了了test1模块和test2模块。 这样最终程序中就会出现两份comm.h的内容。这样就造成了了文件内容的重复。 1.方法1 文件开头加上这一句就ok #prag…

python字符串切片操作

name abcdefghijk name[2:-1] cdefghijname[2:] cdefghijk # 第三个参数是步长 name[2:-1:2] cegi# 字符串反转 name[::-1] name[-1::-1] kjihgfedcba kjihgfedcba

机器思维。一些让我眼前一亮的算法。

用人脑相处了计算机处理数据的方式。而不是 人脑处理的方式—>用计算机的语言表达 人脑处理的方式—>计算机处理的方式—>用计算机的语言表达

python 之 __new__ 方法理解

python的new方法 使用场景不同效果也不一样 一种是指定元类时候&#xff0c; metaclassMyType 类型 这种方式 在解释器执行到 metaclassCrawlerProxyMetaclass 的时候&#xff0c; __new__方法就开始执行&#xff01; 这里的 __new__方法是用来创建类对象的 class CrawlerProx…

详解强制类型转换

今天谈谈类型转换的问题吧&#xff0c;之前我们也遇到过类型转换&#xff0c;比如c语言中这样的赋值&#xff1a; 显然&#xff0c;i和j是不同类型的变量&#xff0c;但是却可以完成赋值&#xff0c;结果是这样的&#xff1a; 其实它们是做了隐式的类型转换&#xff0c;相当于&…

面试--输入一堆随机数(0-1000),这里面会有重复的数字,把他们去除掉。然后由大到小排列。

1.问题说明 11 10 20 40 32 67 40 20 89 300 400 15 10 15 20//只显示1次 32 40//只显示1次 67 89 300 400 正常的算法&#xff1a; 1.遍历所有数组&#xff0c;去除掉重复的数字 2.使用XX排序法&#xff0c;进行数字的排序。 眼前一亮的机器算法 1.生成1-1000的数组&am…

c++之类型萃取

刚刚我们接触过模板类&#xff0c;类似于这样的&#xff1a; 在这个类中&#xff0c;我们如何知道它是什么类型的呢&#xff1f;这里&#xff0c;我们可以在类中加入一个内嵌类型&#xff0c;如&#xff1a; 这样就可以知道它是用户自定义的还是本身类型就拥有的&#xff0c;我…

django xadmin出现的问题

1.File “/home/yuanqi/.virtualenvs/djangodev1/lib/python3.5/site-packages/xadmin/sites.py”, line 9, in reload(sys) import importlib importlib.reload(sys)# sys.setdefaultencoding("utf-8")把相应文件改为上述这样

一道面试题--两个int(32位)整数m和n的二进制表达中,有多少个位(bit)不同

1.问题说明 十进制4 0100 十进制8 1000二进制不同的 0100 1000有两位不同 正常的算法 1.两个数字与1&#xff0c;拿出两个数字的最后一位&#xff0c;比较是否相同&#xff0c;直到右移32次&#xff0c; for (int i 0; i < 32; i){if ((m & 1) ! (n & 1)){count…

时间复杂度空间复杂度

我们编过不少代码&#xff0c;起初学习的时候我们习惯性的认为&#xff0c;只要代码能正确的运行就ok啦~很少考虑代码的优化带来的好处。今天说一下影响代码性能的两个重要指标--时间复杂度&空间复杂度。 时间复杂度&#xff1a;就是函数&#xff08;指数学中的函数&#…

C语言 函数递归例题解析

1.接受一个整形值&#xff08;无符号&#xff09;&#xff0c;把它转换为 字符并打印它模拟实现strlen()函数。3.求n的阶乘4.斐波那契数列总结 1.接受一个整形值&#xff08;无符号&#xff09;&#xff0c;把它转换为 字符并打印它 void fun(int x) {if (x > 9){fun(x/10)…

xpath 简单用法小记

1 xpath定位 没有某个属性的元素 例如定位没有class属性的td tds tr.xpath(.//td[not(class)])