如何使用pipe()系统调用（用法示例） _管道

先决条件：I/O系统调用
【如何使用pipe()系统调用（用法示例）】从概念上讲, 管道是两个进程之间的连接, 以使一个进程的标准输出成为另一进程的标准输入。在UNIX操作系统中, 管道对于相关进程之间的通信(进程间通信)很有用。
管道仅是单向通信, 即我们可以使用管道, 以便一个进程向管道写入数据, 而另一个进程从管道读取数据。它打开一个管道, 该管道是主存储器中被视为"虚拟文件"的区域。
创建过程及其所有子过程均可使用该管道进行读取和写入。一个进程可以写入此"虚拟文件"或管道, 而另一个相关进程可以从中读取。
如果某个进程在将某些内容写入管道之前尝试读取, 则该过程将被挂起, 直到写入某些内容为止。
管道系统调用在进程的打开文件表中找到前两个可用位置, 并将其分配给管道的读取和写入端。

文章图片
C语言语法：

int pipe(int fds[2]); Parameters : fd[0] will be the fd(file descriptor) for the read end of pipe. fd[1] will be the fd for the write end of pipe. Returns : 0 on Success. -1 on error.

管道行为先进先出(先进先出), 管道的行为类似于队列数据结构。读写大小不必在这里匹配。我们可以写512一次只能读取1个字节, 但在管道中一次只能读取1个字节。

// C program to illustrate // pipe system call in C #include < stdio.h> #include < unistd.h> #define MSGSIZE 16 char * msg1 = "hello, world #1" ; char * msg2 = "hello, world #2" ; char * msg3 = "hello, world #3" ; int main() { char inbuf[MSGSIZE]; int p[2], i; if (pipe(p) < 0) exit (1); /* continued */ /* write pipe */write(p[1], msg1, MSGSIZE); write(p[1], msg2, MSGSIZE); write(p[1], msg3, MSGSIZE); for (i = 0; i < 3; i++) { /* read pipe */ read(p[0], inbuf, MSGSIZE); printf ( "% s\n" , inbuf); } return 0; }

输出如下：

hello, world #1 hello, world #2 hello, world #3

父进程和子进程共享管道
当我们使用叉子在任何进程中, 文件描述符在子进程和父进程之间均保持打开状态。如果我们在创建管道后调用fork, 则父级和子级可以通过管道进行通信。

文章图片
以下程序的输出。

// C program to illustrate // pipe system call in C // shared by Parent and Child #include < stdio.h> #include < unistd.h> #define MSGSIZE 16 char * msg1 = "hello, world #1" ; char * msg2 = "hello, world #2" ; char * msg3 = "hello, world #3" ; int main() { char inbuf[MSGSIZE]; int p[2], pid, nbytes; if (pipe(p) < 0) exit (1); /* continued */ if ((pid = fork()) > 0) { write(p[1], msg1, MSGSIZE); write(p[1], msg2, MSGSIZE); write(p[1], msg3, MSGSIZE); // Adding this line will // not hang the program // close(p[1]); wait(NULL); }else { // Adding this line will // not hang the program // close(p[1]); while ((nbytes = read(p[0], inbuf, MSGSIZE)) > 0) printf ( "% s\n" , inbuf); if (nbytes != 0) exit (2); printf ( "Finished reading\n" ); } return 0; }

输出如下：