这是我的代码
#include <iostream>
#include <string>
#include <sys/wait.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <vector>
#include <sstream>
#include <stdio.h>
using namespace std;
int main() {
int pipe_A[2];
int pipe_B[2];
pipe(pipe_A);
pipe(pipe_B);
pid_t pid_A, pid_B, pid_C;
if (!(pid_A = fork())) {
dup2(pipe_A[1], 1); /* redirect standard output to pipe_A write end */
system("./data");
exit(0);
}
if (!(pid_B = fork())) {
dup2(pipe_A[0], 0); /* redirect standard input to pipe_A read end */
dup2(pipe_B[1], 1); /* redirect standard output to pipe_B write end */
system("grep 5");
exit(0);
}
if (!(pid_C = fork())) {
dup2(pipe_B[0], 0); /* redirect standard input to pipe_B read end */
system("grep 2");
exit(0);
}
return 0;
}
其中“./data”是我的测试样本:
for(int i=0;i<100;i++){
cout<<i<<endl;
}
我尝试根据这个 link 构建管道:
显然我的程序不工作。在我运行我的程序之后,将有两个进程一直在执行 pipe_wait(我从系统监视器中看到的)。似乎有些管道应该关闭。我该如何解决?
最佳答案
每个 child 都有自己的父文件描述符拷贝。 dup2
创建了另一个拷贝。在写入端的所有拷贝都关闭之前,管道的读取端不会返回 EOF。
因此,在每次调用 fork
+ dup2
之后,继续关闭
所有四个 pipe_A[0]、pipe_A[1]、 pipe_B[0] 和 pipe_B[1]。
在你 fork 所有的 child 之后,还要在 parent 中关闭它们。 (这在您的示例中不是绝对必要的,因为当 main() 返回时它们将自动关闭。但为了清洁起见,我还是会这样做。)
关于C++ 管道错误,pipe_wait 永远,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9024099/