C语言实现类bash终端时如何强制多pipeline按指定顺序输出结果

你的输出乱序核心是进程等待逻辑存在两处严重错误：

• 首先execute_pipeline函数中，第一个命令调用execvp成功后会直接替换当前进程的地址空间，后面写的wait(&status)和close(fd[0][1])代码完全不会执行，你没有等待当前管道的所有子进程执行完毕，就会导致外层的wait提前返回，直接启动下一条管道命令，两个管道的输出自然会穿插。
• 其次外层的wait(&child)参数错误：wait要求传入的是int*类型的状态存储指针，你直接传入了pid_t类型的进程ID变量，属于未定义行为，大概率会导致wait提前错误返回，进一步加剧顺序混乱。

你不需要修改管道内部的并行逻辑，只要保证前一个完整管道的所有进程全部执行完毕、输出全部落定之后，再启动下一个管道即可，这也是bash等常规shell的默认行为，实现成本最低也最符合用户使用预期。
具体修改点如下：

1. 重构execute_pipeline函数，将所有管道命令都放到子进程中执行，父进程专门负责等待所有子进程退出，不要让父进程自己执行第一个命令：

#include <signal.h>
#include <stdlib.h>
void execute_pipeline(struct command_line *cmds, int num_cmds){
    int numPipes = (num_cmds - 1);
    int fd[numPipes][2];
    pid_t *pids = malloc(num_cmds * sizeof(pid_t));
    if (!pids) {
        perror("malloc");
        return;
    }

    // 创建所有管道
    for(int i = 0; i<numPipes; i++){
        if(pipe(fd[i]) == -1){
            perror("pipe");
            free(pids);
            return;
        }
    }

    // 为每个命令创建子进程
    for(int i = 0; i < num_cmds; i++){
        pid_t pid = fork();
        if(pid < 0){
            perror("fork");
            // 出错时清理已创建的子进程
            for (int j=0; j<i; j++) kill(pids[j], SIGKILL);
            free(pids);
            return;
        }

        if (pid == 0) {
            // 子进程：重定向输入输出
            if (i > 0) {
                dup2(fd[i-1][0], STDIN_FILENO);
            }
            if (i < num_cmds -1) {
                dup2(fd[i][1], STDOUT_FILENO);
            } else if (cmds[i].stdout_file != NULL) {
                // 最后一个命令输出到文件
                int fd_out = open(cmds[i].stdout_file, O_WRONLY | O_CREAT | O_TRUNC, 0644);
                if(fd_out == -1){
                    perror("open output file");
                    exit(1);
                }
                dup2(fd_out, STDOUT_FILENO);
                close(fd_out);
            }

            // 关闭所有不需要的管道fd
            for(int j=0; j<numPipes; j++){
                close(fd[j][0]);
                close(fd[j][1]);
            }

            execvp(cmds[i].tokens[0], cmds[i].tokens);
            perror("execvp");
            exit(1);
        } else {
            pids[i] = pid;
        }
    }

    // 父进程：关闭所有管道
    for(int i=0; i<numPipes; i++){
        close(fd[i][0]);
        close(fd[i][1]);
    }

    // 等待所有子进程执行完毕
    int status;
    for(int i=0; i<num_cmds; i++){
        waitpid(pids[i], &status, 0);
    }

    free(pids);
    return;
}

2. 修正外层的wait调用参数：

pid_t child = fork();
if(child == -1){
    perror("fork");
} else if (child == 0) {
    execute_pipeline(cmds, cmd_count);
    exit(0);
} else {
    printf("Starting child process, pid = %d\n", child);
    int status;
    waitpid(child, &status, 0); // 用waitpid明确等待当前管道子进程，参数传状态变量地址
}

3. 如果需要适配非终端输出场景，可以在每条命令执行前设置标准输出行缓冲：setvbuf(stdout, NULL, _IOLBF, 0);，避免缓冲导致的输出延迟乱序。

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