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程序将不会读取任何内容。可以通过两种方式更改此行为:
- 指定缓冲模式:
有三种缓冲模式:
- 块缓冲区(默认)
- 行缓冲区
- 根本没有缓冲
这里满足您需求的是行缓冲区,因此请使用fifo = open("emg", "w", 1);
代替代替fifo = open("emg", "w");
。1号代替行缓冲区。python文档
- 另一种方法是强制刷新缓冲区,
fifo.flush
在写操作之后使用。