C++管道错误,管道永远等待



这是我的代码

#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;
}

我试图根据这个链接构建一个管道:

显然我的程序不起作用。在我运行程序之后,将有两个进程永远执行pipe_wait(我从系统监视器中看到了这一点)。似乎有一些管道应该关闭。我该怎么修?

每个子级都有自己的父级文件描述符副本。dup2创建了另一个副本。在关闭写入端的所有副本之前,管道的读取端不会返回EOF。

因此,在每次调用fork+dup2之后,继续执行并close pipe_A[0]、pipe_A[1]、pipe_B[0]和pipe_B[1]中的所有四个。

在分叉所有子对象后,还要在父对象中关闭它们。(在您的示例中,这不是绝对必要的,因为当main()返回时,它们将自动关闭。但为了清洁,我无论如何都会这么做。)

最新更新