首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >FIFO管道只在写入端关闭后才读取。

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

Stack Overflow用户
提问于 2015-12-22 08:40:40
回答 3查看 1.7K关注 0票数 3

我试图在python文件和C文件之间创建一个FIFO管道,但问题是当从C文件读取输入时,getline阻塞,直到写入器结束(在python文件中)。

C档案:

代码语言:javascript
运行
复制
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文件:

代码语言:javascript
运行
复制
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()时才会读取数据,而且数据只是一次性读取。这并不是很有帮助,因为我想要一个不断的命令流。

EN

回答 3

Stack Overflow用户

回答已采纳

发布于 2015-12-22 09:10:27

你的问题来自缓冲区。FIFO默认使用块缓冲区。因此,在python中fifo的写缓冲区已满之前,c程序不会读取任何内容。改变这种行为有两种方法:

  • 指定缓冲区模式:

有三种缓冲模式:

  1. 块缓冲区(默认)
  2. 线路缓冲器
  3. 一点缓冲也没有

这里满足您需要的是行缓冲区,所以使用fifo = open("emg", "w", 1);而不是fifo = open("emg", "w");将修复。这里是1号,而不是行缓冲区。python

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

Stack Overflow用户

发布于 2015-12-24 10:13:09

是的,..forcing冲水会解决这个问题。

票数 1
EN

Stack Overflow用户

发布于 2015-12-22 09:05:22

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

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/34411623

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档