7

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

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

我有一个父进程启动一个子进程，并允许它访问我创建的管道连接的一端。现在，当子进程完成、出现故障或其他任何情况时，一切都会停止并关闭连接。此时子进程显示已失效。

然后我希望父进程的连接在阻塞的 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。但事实并非如此。谁能澄清一下？

4

1 回答 1

8

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

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

  1. child_conn.close()在父母中并不意味着孩子应该立即结束
  2. parent_conn.recv只要有人愿意，就不会回来child_conn.send()。如果child_conn打开（在 child或 parent中），那么有机会

如果我确实使用单独的线程，则允许父级关闭自己的连接并且一切正常。请注意，您仍然需要以某种方式知道孩子已经完成，才能做到这一点

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

你能解释一下双工选项吗？

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

于 2013-12-17T09:18:59.050 回答