即使子进程已取消，MultiProcessing Pipe recv块仍会阻塞

Question

阅读有关此主题的几个问题后，我现在知道子进程从父进程继承了文件描述符。当父母关闭连接时，这会使孩子更难收到EOFError。

但是我的情况恰恰相反，我不明白我面临的问题。

我有一个父进程，该进程启动一个子进程，并使其能够访问我创建的Pipe连接的一端。现在，当子进程完成，出现故障或其他任何情况时，所有操作都将停止并关闭连接。此时，子进程显示为已失效。

然后，我希望父进程的连接在阻塞的recv调用上抛出EOFError。但是相反，它只是坐在那里等待。

我在这里想念什么？

编辑

我认为这个例子代表了问题：

from multiprocessing import Process, Pipe
from threading import Thread
import time

class Parent(object):

    def __init__(self):
        self.parent_conn, child_conn = Pipe()
        self.child = Process(target=Child, args=(child_conn,))
        self.child.start()        

        def recv():
            try:
                self.parent_conn.recv()
            except EOFError:
                print "EOF"
            except:
                print "something else"

        # Does not work
        recv()

        # Works fine
        t = Thread(target=recv)
        t.setDaemon(True)
        t.start()

    def close(self):
        self.parent_conn.close()
        self.child.join()

class Child(object):

    def __init__(self, conn):
        conn.close()

if __name__ == "__main__":
    p = Parent()
    time.sleep(1)
    p.close()

如果我确实使用单独的线程，则允许父级关闭其自己的连接，并且一切正常。（请注意，您仍然需要以某种方式知道子进程是如何完成的。）相反，如果我直接调用recv，它将明显阻塞，但是我怀疑一旦子进程关闭其连接，它将引发EOFError。但事实并非如此。谁能澄清？

Answer 1

child_conn.close()在之后添加self.child.start()。使用管道封闭未使用的端头是惯用的。还（可选）提供duplex=False参数。

问题是，我事先不知道它是否会立即关闭。通常，孩子应该能够发送和接收。此外，我仍然不明白为什么这样不起作用。

1. child_conn.close()在父母中并不意味着孩子应该立即结束生活
2. parent_conn.recv直到有机会有人才回来child_conn.send()。如果child_conn被打开（孩子或父母）则是一个机会

如果我确实使用单独的线程，则允许父级关闭其自己的连接，并且一切正常。请注意，您仍然需要知道孩子的工作方式，

您不需要知道它。您可以在子级中打开连接后立即关闭。无论孩子做什么child_conn.close()，self.child.start()都可以在之后打电话给父母。

您还能再多说一些双工选项吗？

duplex = False表示管道是单向的，即，您只能调用parent_conn.recv()和child_conn.send()。否则，它是双向的，并且两个连接都支持send / recv。