[求助]多个pipe怎么写

buzzerrookie

我想用C语言实现一下 ls -l | more | wc，写的代码如下，但没有输出，不知道哪里错了，请各位帮帮忙，谢谢各位。

1. 
   
2. #include <stdio.h>
   
3. #include <unistd.h>
   
4. #include <sys/wait.h>
   
5. 
   
6. int main()
   
7. {
   
8.         pid_t pid[3];
   
9.         int pipe_fd[2];
   
10.         int pipe_fd2[2];
    
11.         int status;
    
12. 
    
13.         char *prog1[3] = {"/bin/ls", "-l", NULL};
    
14.         char *prog2[2] = {"/bin/more", NULL};
    
15.         char *prog3[2] = {"/usr/bin/wc", NULL};
    
16. 
    
17.         if(pipe(pipe_fd) < 0){
    
18.                 perror("pipe 1 failed");
    
19.         }
    
20.         if(pipe(pipe_fd2) < 0){
    
21.                         perror("pipe 2 failed");
    
22.                 }
    
23.         if((pid[0] = fork()) < 0){
    
24.                 perror("fork failed");
    
25.         }
    
26.         if(pid[0] == 0){
    
27.                 close(pipe_fd[0]);
    
28.                 dup2(pipe_fd[1], 1);
    
29.                 close(pipe_fd[1]);
    
30.                 execvp(prog1[0], prog1);
    
31. 
    
32.         }
    
33.         if(pid[0] > 0){
    
34.                 pid[1] = fork();
    
35.                 if(pid[1] == 0){
    
36.                         close(pipe_fd[1]);
    
37.                         dup2(pipe_fd[0], 0);
    
38.                         close(pipe_fd[0]);
    
39. 
    
40.                         close(pipe_fd2[0]);
    
41.                         dup2(pipe_fd2[1], 1);
    
42.                         close(pipe_fd2[1]);
    
43.                         execvp(prog2[0], prog2);
    
44.                 }
    
45.                 if(pid[1]>0){
    
46.                         pid[2] = fork();
    
47.                         if(pid[2] == 0){
    
48.                                 close(pipe_fd2[1]);
    
49.                                 dup2(pipe_fd2[0], 0);
    
50.                                 close(pipe_fd2[0]);
    
51. 
    
52.                                 execvp(prog3[0], prog3);
    
53.                         }
    
54.                 }
    
55.                 close(pipe_fd[0]);
    
56.                 close(pipe_fd[1]);
    
57.                 close(pipe_fd2[0]);
    
58.                 close(pipe_fd2[1]);
    
59.                 waitpid(pid[1], &status, 0);
    
60.         }
    
61.         return 0;
    
62. }
    

复制代码

luckysir

推测：是不是造成了死锁了
也是半生水平呵呵
把管道1 的关闭工作放在创建运行wc的那个子进程之前就行了，我试了一下应该是成功的

luckysir

进一步推测：因为第二个进程运行more,第三个运行wc，而这俩程序都是要看到文件尾才会收工的吧，但是他俩的标准输入现在都成了管道，该管道打开的时候没有指定O_NONBLOCK，所以当管道中没有数据的时候read要么阻塞住，要么在所有的写端fd都被关闭之后返回0，因此别忘了父进程打开的管道没关闭，因此more阻塞住了，随之又阻塞了wc,可是parent还在wait  more。

luckysir

上边描述思路可能是对的，可是细节有错误，刚睡醒的时候脑子就是有些兴奋却不清醒，见谅

应该是parent不及时关闭管道一，结果导致fork后被wc那个进程继承了，然后more和wc互相阻塞。

可能这个推测还是有偏差。)

buzzerrookie

回复 4# luckysir


    非常感谢，我先按您说的这么写吧，尽管我还是不太明白其中的原理。