linux管道学习（一）

最近学习了管道 pipe,在这里进行一下总结。

这里贴一段自己的实做代码

struct node{
int a;
long b;
};

int main()
{
    int field[2];
    pid_t pid;
    char buf[256];
    int returned_count;

    pipe(field);
    //fcntl(field[0], F_SETFL, O_NONBLOCK);
    int status;
    pid = fork();
    if(pid < 0)
    {
        printf("Error In Fork\n");
        exit(1);
    }
    if(pid == 0)
    {
        printf("In Child Process\n");
        close(field[0]);
        node testnode;
        testnode.a = 1;
        testnode.b = 2;
        //sleep(10);
        //write(field[1],"This is a pipe test\n",strlen("This is a pipe test"));
        //write(field[1],"This is another pipe test\n",strlen("This is another pipe test"));
        write(field[1],&testnode,sizeof(testnode));
        testnode.a = 10;
        testnode.b = 20;
        write(field[1],&testnode,sizeof(testnode));
        exit(0);
    }
    else
    {
        printf("In Parent Process\n");
        close(field[1]);
        //read(field[0],buf,sizeof(buf));
        node ptestnode;
        read(field[0],&ptestnode,sizeof(node));
        //printf("Msg %s from Child\n",buf);
        printf("Msg From Child node a= %d, b= %ld\n",ptestnode.a,ptestnode.b);

        read(field[0],&ptestnode,sizeof(node));
        printf("Msg From Child node a= %d, b= %ld\n",ptestnode.a,ptestnode.b);
        //waitpid(pid,&status,0);
    }

    close(field[1]);
}

pipe作为linux进程通讯中的一种常用手段被广泛使用，函数原型为int pipe(int filedes[2]); 其中filedes中的filedes[0]代表读 filedes[1]代表写。

再不使用fcntl函数限定的情况下，管道默认是以阻塞方式进行的。

比如父进程再使用read函数读取管道内容时，如果管道为空，则read函数会阻塞等待。如果将管道设置为读非阻塞，则父进程读取不到管道内容会直接进行下一步，不再等待。

但是父进程中如果使用了wait或waitpid函数，我发现实现效果依然和管道阻塞的情况一样，等待子进程写入，读取内容后才会进行下一步，这点有待研究。

通过read的返回值来进行判断管道中的内容是否读取完毕。

例如

 1 node ptestnode;
 2         int bufcount = 0;
 3         bufcount = read(field[0],&ptestnode,sizeof(node));
 4         //printf("Msg %s from Child\n",buf);
 5         printf("Msg From Child node a= %d, b= %ld\n",ptestnode.a,ptestnode.b);
 6
 7         while(bufcount)
 8         {
 9             bufcount = read(field[0],&ptestnode,sizeof(node));
10             if(!bufcount)
11             {
12                 break;
13             }
14             printf("Msg From Child node a= %d, b= %ld\n",ptestnode.a,ptestnode.b);
15         }
16
17         printf("Pipe Read Over\n");