Python 代码在尝试打开命名管道进行读取时挂起

Question

我正在尝试使用命名管道在守护程序和客户端之间设置两种方式的通信。尝试打开用于输入的命名管道时代码挂起，为什么？

class comm(threading.Thread):

def __init__(self):
    self.srvoutf = './tmp/serverout'
    self.srvinf = './tmp/serverin'
    if os.path.exists(self.srvoutf):
        self.pipein = open(self.srvoutf, 'r') 
        #-----------------------------------------------------Hangs here
    else:
        os.mkfifo(self.srvoutf)
        self.pipein = open(self.srvoutf, 'r')
        #-----------------------------------------------------or here
    if os.path.exists(self.srvinf):
        self.pipeout = os.open(self.srvinf, os.O_WRONLY)
    else:
        os.mkfifo(self.srvinf)
        self.pipeout = os.open(self.srvinf, os.O_WRONLY)
        
    threading.Thread.__init__ ( self )

Answer 1

来自 open() 规范：

当使用 O_RDONLY 打开 FIFO 或
O_WRONLY 设置：

如果设置了 O_NONBLOCK，则
只读的 open() 将返回
毫不拖延。一个 open() 为
如果出现以下情况，只写将返回错误
当前没有进程打开该文件
供阅读。

如果 O_NONBLOCK 被清除，则 open() 用于
只读会阻止调用
线程直到有线程打开文件
用于写作。一个 open() 为
只写会阻止调用
线程直到有线程打开文件
供阅读。

换句话说，当您打开命名管道进行读取时，默认情况下，该打开将阻塞，直到管道的另一端打开进行写入。要解决此问题，请使用 os.open() 并在命名管道的读取端传递 os.O_NONBLOCK 。