为什么被阻塞了

buzzerrookie

我想实现 ls | more | wc，但exec的顺序是反着来的，运行后始终没有结果，我猜是被阻塞了。请各位帮忙看一下，谢谢了。

1. 
   
2. /*
   
3. * ls | more | wc
   
4. */
   
5. #include <stdio.h>
   
6. #include <unistd.h>
   
7. #include <sys/wait.h>
   
8. 
   
9. int main()
   
10. {
    
11.         pid_t pids[10];
    
12.         int pipes[10][2];
    
13.         char *ls[] = {"ls", NULL};
    
14.         char *more[] = {"more", NULL};
    
15.         char *wc[] = {"wc", NULL};
    
16.         int i;
    
17. 
    
18.         /*
    
19.          * wc
    
20.          */
    
21.         for(i = 0; i < 10; i++){
    
22.                 if(pipe(pipes[i]) == -1){
    
23.                         printf("pipe error\n");
    
24.                 }
    
25.         }
    
26.         if((pids[2] = fork()) == -1){
    
27.                 perror("fork error");
    
28.         } else if(pids[2] == 0){
    
29.                 //输入
    
30.                 close(pipes[1][1]);
    
31.                 dup2(pipes[1][0], STDIN_FILENO);
    
32.                 close(pipes[1][0]);
    
33. 
    
34.                 if(execvp(wc[0], wc) == -1){
    
35.                         printf("exec %s failed\n", ls[0]);
    
36.                 }
    
37.         } else if(pids[2] > 0){
    
38.         }
    
39.         /*
    
40.          * more
    
41.          */
    
42.         if((pids[1] = fork()) == -1){
    
43.                 perror("fork error");
    
44.         } else if(pids[1] == 0){
    
45.                 //输入
    
46.                 close(pipes[0][1]);
    
47.                 dup2(pipes[0][0], STDIN_FILENO);
    
48.                 close(pipes[0][0]);
    
49.                 //输出
    
50.                 close(pipes[1][0]);
    
51.                 dup2(pipes[1][1], STDOUT_FILENO);
    
52.                 close(pipes[1][1]);
    
53. 
    
54.                 if(execvp(more[0], more) == -1){
    
55.                         printf("exec %s failed\n", more[0]);
    
56.                 }
    
57.         } else if(pids[1] > 0){
    
58.         }
    
59.         /*
    
60.          * ls
    
61.          */
    
62.         if((pids[0] = fork()) == -1){
    
63.                 perror("fork error");
    
64.         } else if(pids[0] == 0){
    
65.                 //输出
    
66.                 close(pipes[0][0]);
    
67.                 dup2(pipes[0][1], STDOUT_FILENO);
    
68.                 close(pipes[0][1]);
    
69. 
    
70.                 if(execvp(ls[0], ls) == -1){
    
71.                         printf("exec %s failed\n", ls[0]);
    
72.                 }
    
73.         } else if(pids[0] > 0){
    
74.                 waitpid(pids[0], NULL, 0);
    
75.         }
    
76. 
    
77.         close(pipes[0][0]);
    
78.         close(pipes[0][1]);
    
79.         waitpid(pids[1], NULL, 0);
    
80.         close(pipes[1][0]);
    
81.         close(pipes[1][1]);
    
82.         waitpid(pids[2], NULL, 0);
    
83. 
    
84.         return 0;
    
85. }
    

复制代码

chllcy88

帮顶,如果只是1个管道的话,ls|more没问题,但2个管道就在more处阻塞了.希望高人指点下.

1. #include <stdio.h>
   
2. 
   
3. #include <unistd.h>
   
4. 
   
5. #include <sys/wait.h>
   
6. #include <sys/types.h>
   
7. #include <cstdlib>
   
8. #include <iostream>
   
9. using namespace std;
   
10. 
    
11. int isready(int fd)
    
12. {
    
13.         int rc;
    
14.         fd_set fds;
    
15.         struct timeval tv;
    
16. 
    
17.         FD_ZERO(&fds);
    
18.         FD_SET(fd, &fds);
    
19.         tv.tv_sec = 1;
    
20.         tv.tv_usec = 0;
    
21.         rc = select(fd + 1, &fds, NULL, NULL, &tv);
    
22.         if (rc < 0) //error
    
23.                 return -1;
    
24. 
    
25.         return FD_ISSET(fd, &fds) ? 1 : 0;
    
26. }
    
27. int main()
    
28. 
    
29. {
    
30. 
    
31.         pid_t pids[10];
    
32. 
    
33.         int pipes[10][2];
    
34. 
    
35.         char *ls[] =
    
36.         { "ls", NULL };
    
37. 
    
38.         char *more[] =
    
39.         { "more", NULL };
    
40. 
    
41.         char *wc[] =
    
42.         { "wc", NULL };
    
43. 
    
44.         int i, status;
    
45. 
    
46.         for (i = 0; i < 10; i++)
    
47.         {
    
48. 
    
49.                 if (pipe(pipes[i]) == -1)
    
50.                 {
    
51. 
    
52.                         printf("pipe error\n");
    
53. 
    
54.                 }
    
55. 
    
56.         }
    
57. 
    
58.         if ((pids[0] = fork()) == -1)
    
59.         {
    
60. 
    
61.                 perror("fork error");
    
62. 
    
63.         }
    
64.         else if (pids[0] == 0)
    
65.         {
    
66. 
    
67.                 //输出
    
68. 
    
69.                 close(pipes[0][0]);
    
70.                 close(STDOUT_FILENO);
    
71. 
    
72.                 dup2(pipes[0][1], STDOUT_FILENO);
    
73. 
    
74.                 close(pipes[0][1]);
    
75. 
    
76.                 if (execvp(ls[0], ls) == -1)
    
77.                 {
    
78. 
    
79.                         printf("exec %s failed\n", ls[0]);
    
80. 
    
81.                 }
    
82. 
    
83.         }
    
84.         else if (pids[0] > 0)
    
85.         {
    
86. 
    
87.                 wait(NULL);
    
88. 
    
89.                 if ((pids[2] = fork()) == -1)
    
90.                 {
    
91. 
    
92.                         perror("fork error");
    
93. 
    
94.                 }
    
95.                 else if (pids[2] == 0)
    
96.                 {
    
97. 
    
98.                         //输入
    
99.                         //sleep(2);
    
100.                         if (isready(pipes[0][0]) > 0)
     
101.                         {
     
102.                                 cout << "ready" << endl;
     
103.                                 close(pipes[0][1]);
     
104.                                 close(STDIN_FILENO);
     
105.                                 dup2(pipes[0][0], STDIN_FILENO);
     
106. 
     
107.                                 close(pipes[0][0]);
     
108. 
     
109.                                 //输出
     
110. 
     
111.                                 close(pipes[1][0]);
     
112.                                 close(STDOUT_FILENO);
     
113.                                 dup2(pipes[1][1], STDOUT_FILENO);
     
114.                                 dup2(pipes[1][1], STDERR_FILENO);
     
115. 
     
116.                                 close(pipes[1][1]);
     
117. 
     
118.                                 if (execvp(more[0], more) == -1)
     
119.                                 {
     
120. 
     
121.                                         printf("exec %s failed\n", more[0]);
     
122. 
     
123.                                 }
     
124.                         }
     
125. 
     
126.                 }
     
127.                 else if (pids[2] > 0)
     
128.                 {
     
129.                         //输入
     
130.                         wait(NULL);
     
131.                         ////waitpid( pids[2], &status, 0 );
     
132. 
     
133.                         if (isready(pipes[1][0]) > 0)
     
134.                         {
     
135.                                 cout << "ready 2" << endl;
     
136.                                 close(pipes[1][1]);
     
137.                                 close(STDIN_FILENO);
     
138. 
     
139.                                 dup2(pipes[1][0], STDIN_FILENO);
     
140. 
     
141.                                 close(pipes[1][0]);
     
142. 
     
143.                                 if (execvp(wc[0], wc) == -1)
     
144.                                 {
     
145. 
     
146.                                         printf("exec %s failed\n", ls[0]);
     
147. 
     
148.                                 }
     
149.                         }
     
150. 
     
151.                 }
     
152. 
     
153.         }
     
154. 
     
155.         close(pipes[0][0]);
     
156. 
     
157.         close(pipes[0][1]);
     
158. 
     
159.         close(pipes[1][0]);
     
160. 
     
161.         close(pipes[1][1]);
     
162. 
     
163.         return 0;
     
164. 
     
165. }
     

复制代码

buzzerrookie

回复 2# chllcy88


    是啊，我试两个的也没问题，一扩展就有问题了。

buzzerrookie

回复 2# chllcy88


    看 http://bbs.chinaunix.net/thread-3683342-1-1.html  也是我问的，看10楼和11楼