Python：检查命名管道是否有数据

我的Unix系统上的Python3进程一直在运行,我希望能够通过偶尔运行的其他进程的命名管道随机发送数据.如果命名管道没有数据,我希望我的进程继续做其他事情,所以我需要检查它是否有没有阻塞的数据.

我无法弄清楚如何在不打开它的情况下进行检查,但是除非我设置非阻塞标志,否则打开块.如果我设置了标志,如果我在读取之前或读取期间碰巧写入管道,它就会崩溃.

这是我设法做到的最好的：

import os
fifo = "pipe_test.fifo"
dOne= False
fd = os.open(fifo, os.O_RDONLY | os.O_NONBLOCK)
while not done:
try:
s = os.read(fd, 1024) # buffer size may need tweaking
print(s)
dOne= True
except BlockingIOError as e:
pass
os.close(fd)


如果管道中没有数据,我会得到b“”,然后退出.如果管道中有数据,它会获得一次异常,重试,然后获取数据.好像我做错了什么,可能会遇到奇怪的竞争条件.有没有更好的方法来做到这一点？

解决方法:

如果您可以更改客户端的代码,我不会使用命名管道,而是UNIX domain sockets,因为它们支持数据报：

import errno, fcntl, os, socket


服务器：

# bind socket
sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
sock.bind('pipe_test.fifo')
# set socket non-blocking
fcntl.fcntl(sock.fileno(), fcntl.F_SETFL, os.O_NONBLOCK)
# get a datagram
try:
datagram = sock.recv(1024)
except (OSError, socket.error) as ex:
if ex.errno not in (errno.EINTR, errno.EAGAIN):
raise
else:
print('Datagram: %r' % datagram)


客户：

sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
sock.sendto('Hello!', 'pipe_test.fifo')


但您可能希望查看multithreading而不是使用非阻塞套接字.