FIFO管道仅在写入结束后读取


问题内容

我正在尝试在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()时才读取数据,并且一次只能读取一次。这并不是真正有用的方法,因为我希望源源不断的命令。


问题答案:

您的问题来自缓冲区。FIFO默认使用块缓冲区。因此,在python中fifo的写缓冲区已满之前,c程序将不会读取任何内容。可以通过两种方式更改此行为:

  • 指定缓冲模式:

有三种缓冲模式:

  1. 块缓冲区(默认)
  2. 行缓冲区
  3. 根本没有缓冲

这里满足您需求的是行缓冲区,因此请使用fifo = open("emg", "w", 1);代替代替fifo = open("emg", "w");。1号代替行缓冲区。python文档

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