实现bash管道功能时grep子进程阻塞退出问题求助

我在开发minishell时，用pipe()和fork()实现bash的command | command管道功能。ls -al | head的代码能正常执行并退出，但ls -al | grep txt的代码虽然能输出结果，却卡在第二个wait()无法推进，导致进程无法退出。推测是grep在管道数据耗尽后还在等待输入，目前用usleep()的方案太不稳定，想找个可靠的方法让父进程在子进程执行完成后恢复。

原测试代码 #

实现ls -al | head的代码 #

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <errno.h>

int main (){
    int fd[2], status;
    pipe(fd);
    if(fork() == 0){
        close(fd[0]);
        dup2(fd[1], STDOUT_FILENO);
        close(fd[1]);
        execlp("ls", "ls", "-al", NULL);
    }
    else
        wait(&status);
    if(fork() == 0){
        close(fd[1]);
        dup2(fd[0], STDIN_FILENO);
        close(fd[0]);
        execlp("head", "head", NULL);
    }
    else 
        wait(&status);
    close(fd[1]);
    close(fd[0]);
}

实现ls -al | grep txt的代码 #

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <errno.h>

int main (){
    int fd[2], status;
    pipe(fd);
    if(fork() == 0){
        close(fd[0]);
        dup2(fd[1], STDOUT_FILENO);
        close(fd[1]);
        execlp("ls", "ls", "-al", NULL);
    }
    else
        wait(&status);
    if(fork() == 0){
        close(fd[1]);
        dup2(fd[0], STDIN_FILENO);
        close(fd[0]);
        execlp("grep", "grep", "txt", NULL);
    }
    else 
        wait(&status);
    close(fd[1]);
    close(fd[0]);
}

问题分析 #

你代码的核心问题有两个：

1. 父进程未及时关闭管道文件描述符：创建第二个子进程前，父进程还握着管道的写端fd[1]。grep会一直读取输入直到所有写端被关闭，它不知道父进程不会再写数据，因此会一直阻塞等待，导致父进程的wait()永远无法返回。而head只读取前10行就主动退出，所以不受这个问题影响。
2. 串行创建子进程：先等第一个子进程结束再创建第二个，这种逻辑不符合管道“实时传递数据”的设计，只适配head这类提前终止的命令，不适配grep这类持续读输入的命令。

修复方案 #

修复后的通用代码 #

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <errno.h>

int main (){
    int fd[2], status;
    pid_t pid1, pid2;

    // 创建管道，失败则报错退出
    if (pipe(fd) == -1) {
        perror("pipe failed");
        exit(EXIT_FAILURE);
    }

    // 第一个子进程：执行ls -al
    pid1 = fork();
    if(pid1 == 0){
        close(fd[0]);          // 关闭不需要的读端
        dup2(fd[1], STDOUT_FILENO); // 把stdout重定向到管道写端
        close(fd[1]);          // 重定向后关闭原写端
        execlp("ls", "ls", "-al", NULL);
        perror("execlp ls failed"); // execlp失败才会执行到这里
        exit(EXIT_FAILURE);
    }

    // 第二个子进程：执行grep txt（替换成head就是ls -al | head）
    pid2 = fork();
    if(pid2 == 0){
        close(fd[1]);          // 关闭不需要的写端
        dup2(fd[0], STDIN_FILENO);  // 把stdin重定向到管道读端
        close(fd[0]);          // 重定向后关闭原读端
        execlp("grep", "grep", "txt", NULL);
        perror("execlp grep failed");
        exit(EXIT_FAILURE);
    }

    // 父进程必须立即关闭管道的两端！
    close(fd[0]);
    close(fd[1]);

    // 等待两个子进程依次退出
    waitpid(pid1, &status, 0);
    waitpid(pid2, &status, 0);

    return 0;
}

关键修复点 #

• 父进程及时关闭管道两端：这是解决grep阻塞的核心。父进程不使用管道，必须关闭持有的描述符，让子进程明确知道没有更多数据会写入管道。
• 并行创建子进程：两个子进程同时运行，符合管道的数据流逻辑，适配所有类型的命令。
• 用waitpid()精准等待：指定等待特定子进程，避免wait()的不确定性，逻辑更清晰。

内容的提问来源于stack exchange，提问作者DH2