首页 > 代码库 > 简述Linux进程间通信之管道pipe(下)

简述Linux进程间通信之管道pipe(下)

  上篇文章的简述,我相信大家对管道的概念有了模糊的认识,本文通过代码实例来强化对管道的理解.

  创建管道主要用到pipe函数,pipe的原型如下:

一、函数原型

  #include <unistd.h>

  int pipe(int pipefd[2]);

  参数:一个整型数组,管道创建成功后,pipefd[0]表示管道的读端,pipefd[1]表示管道的写端.

  成功返回0,失败返回-1,同时errno被设置.

二、父子进程通信

  上文中,我们描述了父子进程通过管道来进行通信的整个过程,现在我们用C语言来实现:

#include<stdio.h>
#include<unistd.h>
int main(){
    int fds[2] = {0};
    //1.创建管道
    if(pipe(fds)==-1){
        perror("pipe");
        return 1;
    }
    //2.fork子进程
    pid_t pid = fork();
    if(pid > 0){        //father
        //3.父进程关闭读端,向写端写入数据
        close(fds[0]);
        char buff[1024]={0};
        printf("parent to child#");
        fflush(stdout);
        ssize_t s = read(0,buff,sizeof(buff)-1);
        buff[s-1] = 0;
        write(fds[1],buff,s);
        close(fds[1]);
    }else if(pid==0){   //child
        //3.子进程关闭写端,从读端读出数据
        close(fds[1]);
        char buff[1024]={0};
        ssize_t s = read(fds[0],buff,sizeof(buff));
        printf("child to receive#%s\n",buff);
        close(fds[0]);
    }else{
        perror("fork");
        return 2;
    }
    wait(NULL); //回收子进程
    return 0;
}

  上述代码中,我们展示的是父子进程普通的通信情况,除了正常情况之外,我们还需考虑四种异常情况:

三、四种情况

   为了节省文章篇幅,代码部分省略,读者可以自行测试.

  1.父进程不断向管道中写数据,子进程不从管道中读取数据,子进程fds[0]读端保持开启.

  这种情况将导致管道被写满,同时父进程被阻塞,直到管道中有空位置.

  2.父进程不断向管道中写数据,子进程不从管道中读取数据,子进程关闭了fds[0]读端.

  这种情况下,父进程会收到SIGPIPE信号,进而被终止.

  3.父进程向管道中写了一些数据,子进程不断从管道中读取数据,父进程fds[1]写端保持开启.

  这种情况下,子进程将管道中数据读取完毕之后,会进入阻塞状态.直到管道中有新数据产生.

  4.父进程向管道中写了一些数据,子进程不断从管道中读取数据,父进程关闭了fds[1]写端.

  这种情况下,子进程会读完管道中数据,最后read返回0,就像读到文件末尾一样.

简述Linux进程间通信之管道pipe(下)