前文已经将如何创建多进程和如何回收子进程资源进行了详细的分析,在这篇文章中,我与大家一起分享进程间的通信.
在Linux中,pipe()
函数用于创建一个管道,以便进程之间可以相互通信,值得强调的是,pipe()
函数创建的是无名管道,无名管道主要用于父子进程之间的通信,数据只能在一个方向上流动,若双方建立通信,需要建立起两个管道。
要使用pipe()函数,需要包含头文件:
#include <unistd.h>
pipe()函数定义如下:
int pipe(int filedes[2]);
其中filedes
是一个整数数组,用于存储两个文件描述符。filedes[0]
是读端文件描述符,filedes[1]
是写端文件描述符。
?先描述代码的主要思路,创建无名管道并创建两个进程,子进程循环4次给父进程发送数据,父进程接收并输出数据.
#include <sys/types.h>
#include <unistd.h>
#include <iostream>
#include <sys/wait.h>
#include <string.h>
#include <unistd.h> // for sleep
int main() {
int pipefd[2];
int a = pipe(pipefd);
if (a == -1) {
perror("pipe");
return 1;
}
pid_t pid = fork(); //一定要在创建管道之后,放到管道创建之前会产生意想不到的错误
if (pid == 0) { // 子进程
char str[] = "hello";
int i=1;
while(i<5){
write(pipefd[1], str, strlen(str) + 1); // 写入数据到管道,包括结尾的空字符
sleep(1); // 等待子进程完成写入操作
i++;
}
} else if (pid > 0) { // 父进程
char mess[1024];
int j=1;
while(j<5){
int len = read(pipefd[0], mess, sizeof(mess) ); // 从管道读取数据,减去一个字符的空间给空字符
std::cout << "父进程" << mess << std::endl; // 输出读取到的数据
j++;
}
wait(&pid); // 等待子进程结束
}
return 0; // 返回0表示程序正常结束
}
运行程序得到结果:
可以看到,我们成功实现了父子进程之间的通信!