UNIX FIFO：如果我不关闭 fifo 的输入端，进程就会挂起

Question

我刚刚开始使用 UNIX FIFO，并且在试验我的第一个 FIFO 程序时发现了一些东西。该程序的工作方式如下：创建 FIFO 后，使用 fork() 函数启动两个进程。子进程通过 FIFO 读取父进程传递给他的内容，并将其打印在屏幕上。交换的数据是指定为参数的字符串。问题是：在父部分中，如果我忘记关闭 FIFO 的输入端（意味着我排除 close(fd) 行），程序就会挂起，即使之间的数据进程已正确交换。否则，一切正常，程序终止而不会挂起。有人可以解释一下为什么吗？

感谢您的耐心等待。下面是main函数的代码：

int main(int argc, char *argv[])
{
    if(argc != 2)
    {
        printf("An argument must be specified\n");
        return -1;
    }   

    int ret = mkfifo("./fifo.txt", 0644);
    char buf;

    if(ret < 0)
    {
        perror("Error creating FIFO");
        return -1;
    }

    pid_t pid = fork();

    if(pid < 0)
    {
        perror("Error creating child process");
        return -1;
    }

    if(pid == 0) /* child */
    {
        int fd = open("./fifo.txt", O_RDONLY); /* opens the fifo in reading mode */

        while(read(fd, &buf, 1) > 0)
        {
            write(STDOUT_FILENO, &buf, 1);
        }
        write(STDOUT_FILENO, "\n", 1);
        close(fd);
        return 0;
    }
    else /* father */
    {
        int fd = open("./fifo.txt", O_WRONLY); /* opens the fifo in writing mode */

        write(fd, argv[1], strlen(argv[1]));
        close(fd);
        waitpid(pid, NULL, 0);
        return 0;
    }
}

Answer 1

read(2) 会阻塞，直到有可用字符或另一端关闭通道为止。父进程必须关闭管道才能让最后一个子进程 read() 返回。如果在父进程中省略 close(fd)，子进程将阻塞在 read() 中，直到父进程退出（自动关闭管道），但父进程会挂起waitpid() 直到子进程退出。

Answer 2

首先，您发布的代码存在几个问题。

1. 没有 #include 指令，因此您调用的任何函数的范围内都没有原型。 C89 需要可变参数函数的原型，例如 printf() ； C99 需要所有 函数的原型。 C89 和 C99 都需要在 O_RDONLY、O_WRONLY、STDOUT_FILENO 和 NULL 范围内进行声明。
2. -1 不是 main() 允许的返回值。
3. C89 不允许混合声明和语句。

一个小问题：通常的命名法是“父母和孩子”，而不是“父亲和孩子”。

我修改了你的程序来纠正这个问题并提高可读性：

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>

#include <fcntl.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>

int
main(int argc, char *argv[])
{
    if (argc != 2) {
        printf("An argument must be specified\n");
        return 1;
    }

    int ret = mkfifo("./fifo.txt", 0644);
    char buf;

    if (ret < 0) {
        perror("Error creating FIFO");
        return 1;
    }

    pid_t pid = fork();

    if (pid < 0) {
        perror("Error creating child process");
        return 1;
    }

    if (pid == 0) { /* child */
        int fd = open("./fifo.txt", O_RDONLY); /* opens the fifo in reading mode */

        while(read(fd, &buf, 1) > 0) {
            write(STDOUT_FILENO, &buf, 1);
        }
        write(STDOUT_FILENO, "\n", 1);
        close(fd);
        return 0;
    } else { /* parent */
        int fd = open("./fifo.txt", O_WRONLY); /* opens the fifo in writing mode */

        write(fd, argv[1], strlen(argv[1]));
        close(fd);
        waitpid(pid, NULL, 0);
        return 0;
    }
}

但最重要的是，你没有提到你正在使用什么操作系统和编译器。

我无法重现该问题，并且我怀疑它可能与上面列出的问题之一有关。