FIFO管道只有在写入端关闭后才能读取。

Question

我将为您翻译有关IT技术的内容。以下是需要翻译的内容：

我正在尝试创建一个Python文件和C文件之间的FIFO管道，但问题在于当从C文件中读取输入时，getline会阻塞直到写入端（在Python文件中）关闭。

C文件：

char fifo_emg[] = "emg";
mkfifo(fifo_emg, S_IRWXU);

int fd_emg = open(fifo_emg, O_RDONLY);
FILE* fp = fdopen(fd_emg, "r");

char *line = NULL;
size_t len = 0;
ssize_t _read;
printf("Both ends open. Reading commands...\n");
while ((_read = getline(&line, &len, fp)) != -1) {
    printf("Comamnd: %s", line);
}   

Python文件:

fifo = open("emg", "w");

while 1:
    line = raw_input("ENTER COMMAND: ")
    if line[0] == '!':
        break
    else:
        fifo.write(line + '\n')

fifo.close()

当我同时运行两个文件时，我希望从C文件输出的内容能够在通过Python输入时立即显示为“Command: foo”。然而，只有在调用fifo.close()时才会读取数据，并且一次性读取所有数据。这并不是很有帮助，因为我需要一个连续的命令流。

- arahoomam

---

在 fifo.write(...) 之后尝试使用 fifo.flush()。 - user253751

这正是我所需要的！非常感谢！ - arahoomam

Answer 1

你的问题源于缓冲区。FIFO默认使用块缓冲区。因此，C程序在Python的FIFO写入缓冲区填满之前不会读取任何内容。解决这个问题有两种方法：

• 指定缓冲模式：

有三种缓冲模式：

1. 块缓冲（默认）
2. 行缓冲
3. 无缓冲

在这里满足你的需求的是行缓冲，所以使用fifo = open("emg", "w", 1);代替fifo = open("emg", "w");将解决问题，其中1代表行缓冲。 Python文档

• 另一种方法是强制刷新缓冲区，在写操作后使用fifo.flush。

- oxnz

Answer 2

是的，强制刷新将解决这个问题。

- user3422957

Answer 3

正如immibis在评论中所说，fifo.flush()解决了我的问题！

- arahoomam