(11)《基于Linux的C编程与内核导读》--进程间管道通信(一)

2024-04-06 01:32

本文主要是介绍(11)《基于Linux的C编程与内核导读》--进程间管道通信(一),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

3.3.3 进程间管道通信(一)

本节我们学习利用管道实现进程间的通信。这中间用到一个关键的系统调用pipe()函数。其格式为:

int fd[2];

pipe(fd);

 

其中,fd[2]是供进程使用的文件描述符数组,fd[0]用于写,fd[1]用于读。为了协调双方的通信,管道通信机制必须提供以下三方面的协调能力:

1、互斥。当一个进程正在对pipe进行读/写操作时,另外一个进程必须等待,程序中使用lockf(fd[1],1,0)函数实现对管道的加锁操作,用lockf(fd[1],0,0)解除管道的锁定。

2、同步。当写进程把一定数量的数据写入pipe后,便去睡眠等待,直到读进程取走数据后,再把它唤醒。当读进程试图从一空管道读取数据时,也应睡眠等待,直至写进程将数据写入管道后,才将其唤醒。

3、判断对方是否存在。只有确定写进程和读进程都存在的情况下,才能通过管道进行通信。

下面我们就具体编写一个进程间管道通信的例子。

 

程序3.3如下:

/*************本程序用于进程间的管道通信*****************/

#include

#include

#include

int pid1,pid2;

main()

{

int fd[2];

char OutPipe[100],InPipe[100];

pipe(fd);                   /*创建管道 */

while((pid1 = fork()) == -1);

if(pid1 == 0)     /*子进程1执行管道写操作 */

{

lockf(fd[1],1,0);         /*锁定管道 */

/*****OutPipe数组赋值******/

sprintf(OutPipe,"Child process 1 is sending message!/n");

write(fd[1],OutPipe,50);      /*向管道中写入数据 */

sleep(5);

lockf(fd[1],0,0);               /*管道解锁*/

exit(0);

}

else

{

while((pid2 = fork()) == -1);

if(pid2 == 0)     /*子进程2执行管道写操作 */

{

lockf(fd[1],1,0);         /*锁定管道 */

sprintf(OutPipe,"Child process 2 is sending message!/n");

write(fd[1],OutPipe,50);   /*向管道中写入数据 */

sleep(5);

lockf(fd[1],0,0);          /*管道解锁*/

exit(0);

}

else    /*父进程执行管道读操作*/

{

wait(0);                /*等待子进程1结束*/

read(fd[0],InPipe,50);      /*从管道中读出数据*/

printf("%s/n",InPipe);

wait(0);                /*等待子进程2结束*/

read(fd[0],InPipe,50);      /*从管道中读出数据*/

printf("%s/n",InPipe);

exit(0);

}

}

}

 

结果分析:

子进程1将字符串“Child process 1 is sending message!”写入管道;子进程2将字符串“Child process 2 is sending message!”写入管道。父进程分别使用wait(0)函数来等待子进程执行结束,然后从管道中读出数据,并分别在屏幕上显示出来。所以此程序执行的结果是:

Child process 1 is sending message!

Child process 2 is sending message!

 

 原文地址 http://www.openlab.net.cn/blogs/zsb/archive/2005/08/30/444672.aspx

这篇关于(11)《基于Linux的C编程与内核导读》--进程间管道通信(一)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/878666

相关文章

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

Linux进程CPU绑定优化与实践过程

《Linux进程CPU绑定优化与实践过程》Linux支持进程绑定至特定CPU核心,通过sched_setaffinity系统调用和taskset工具实现,优化缓存效率与上下文切换,提升多核计算性能,适... 目录1. 多核处理器及并行计算概念1.1 多核处理器架构概述1.2 并行计算的含义及重要性1.3 并

Linux线程之线程的创建、属性、回收、退出、取消方式

《Linux线程之线程的创建、属性、回收、退出、取消方式》文章总结了线程管理核心知识:线程号唯一、创建方式、属性设置(如分离状态与栈大小)、回收机制(join/detach)、退出方法(返回/pthr... 目录1. 线程号2. 线程的创建3. 线程属性4. 线程的回收5. 线程的退出6. 线程的取消7.

Linux下进程的CPU配置与线程绑定过程

《Linux下进程的CPU配置与线程绑定过程》本文介绍Linux系统中基于进程和线程的CPU配置方法,通过taskset命令和pthread库调整亲和力,将进程/线程绑定到特定CPU核心以优化资源分配... 目录1 基于进程的CPU配置1.1 对CPU亲和力的配置1.2 绑定进程到指定CPU核上运行2 基于

golang程序打包成脚本部署到Linux系统方式

《golang程序打包成脚本部署到Linux系统方式》Golang程序通过本地编译(设置GOOS为linux生成无后缀二进制文件),上传至Linux服务器后赋权执行,使用nohup命令实现后台运行,完... 目录本地编译golang程序上传Golang二进制文件到linux服务器总结本地编译Golang程序

Linux下删除乱码文件和目录的实现方式

《Linux下删除乱码文件和目录的实现方式》:本文主要介绍Linux下删除乱码文件和目录的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录linux下删除乱码文件和目录方法1方法2总结Linux下删除乱码文件和目录方法1使用ls -i命令找到文件或目录

Linux在线解压jar包的实现方式

《Linux在线解压jar包的实现方式》:本文主要介绍Linux在线解压jar包的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录linux在线解压jar包解压 jar包的步骤总结Linux在线解压jar包在 Centos 中解压 jar 包可以使用 u

linux解压缩 xxx.jar文件进行内部操作过程

《linux解压缩xxx.jar文件进行内部操作过程》:本文主要介绍linux解压缩xxx.jar文件进行内部操作,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、解压文件二、压缩文件总结一、解压文件1、把 xxx.jar 文件放在服务器上,并进入当前目录#

Linux系统性能检测命令详解

《Linux系统性能检测命令详解》本文介绍了Linux系统常用的监控命令(如top、vmstat、iostat、htop等)及其参数功能,涵盖进程状态、内存使用、磁盘I/O、系统负载等多维度资源监控,... 目录toppsuptimevmstatIOStatiotopslabtophtopdstatnmon

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab