Python阅读命名PIPE

Question

我有一个在Linux中的命名管道，我想从Python读取它。问题是python进程不断消耗一个核心（100％）。我的代码如下：

FIFO = '/var/run/mypipe' 
os.mkfifo(FIFO) 
with open(FIFO) as fifo: 
    while True: 
     line = fifo.read() 

我要问，如果“睡眠”会帮助的情况或处理从管会损失一些输入数据。我无法控制输入，所以我不知道数据输入的频率。我读了关于选择和民意调查，但我没有找到任何我的问题的例子。最后，我想问一下，100％的使用是否会对数据输入产生任何影响（丢失或什么？）。

编辑：我不想打破循环。我希望这个过程持续运行，并'听到'来自管道的数据。

Answer 1

在典型的UNIX方式，read(2)返回0字节，以指示结束文件这可能意味着：

• 有在文件
• 没有更多的字节的插座的另一端具有关闭连接
• 作家已经完成了管

在你的情况，fifo.read()将返回一个空字符串，因为作者已经关闭了文件描述符。

你应该检测的情况下，打破了你的循环：

reader.py：

import os 
import errno 

FIFO = 'mypipe' 

try: 
    os.mkfifo(FIFO) 
except OSError as oe: 
    if oe.errno != errno.EEXIST: 
     raise 

print("Opening FIFO...") 
with open(FIFO) as fifo: 
    print("FIFO opened") 
    while True: 
     data = fifo.read() 
     if len(data) == 0: 
      print("Writer closed") 
      break 
     print('Read: "{0}"'.format(data)) 

例会议

1号航站楼：

$ python reader.py 
Opening FIFO... 
<blocks> 

2号航站楼：

$ echo -n 'hello' > mypipe 

1号航站楼：

FIFO opened 
Read: "hello" 
Writer closed 
$ 

---

更新1 - 不断地重新打开

表明您想保留名单即使在作家关闭之后，也可能会写入管道。

为了有效地做到这一点，你可以（也应该）采取的是

通常情况下，打开FIFO模块，直至另一端也打开了事实。

在这里，我在open和read循环周围添加了另一个循环。这样一来，一旦管道被关闭，该代码将尝试重新打开它，这将阻止，直到另一位作家打开管道：

import os 
import errno 

FIFO = 'mypipe' 

try: 
    os.mkfifo(FIFO) 
except OSError as oe: 
    if oe.errno != errno.EEXIST: 
     raise 

while True: 
    print("Opening FIFO...") 
    with open(FIFO) as fifo: 
     print("FIFO opened") 
     while True: 
      data = fifo.read() 
      if len(data) == 0: 
       print("Writer closed") 
       break 
      print('Read: "{0}"'.format(data)) 

---

1号航站楼：

$ python reader.py 
Opening FIFO... 
<blocks> 

2号航站楼：

$ echo -n 'hello' > mypipe 

1号航站楼：

FIFO opened 
Read: "hello" 
Writer closed 
Opening FIFO... 
<blocks> 

2号航站楼：

$ echo -n 'hello' > mypipe 

1号航站楼：

FIFO opened 
Read: "hello" 
Writer closed 
Opening FIFO... 
<blocks> 

...等等。

---

您可以通过阅读man页管道了解更多：

• PIPE(7) - Linux Programmer's Manual
• FIFO(7) - Linux Programmer's Manual