Python 多处理管道 recv() 文档不清楚还是我错过了什么？

Question

我最近一直在学习如何使用 Python 多处理模块，并阅读了官方文档。在16.6.1.2. Exchanging objects between processes 中有一个关于使用管道交换数据的简单示例。

并且，在16.6.2.4. Connection Objects 中有这样的声明，引用了“如果没有任何东西可以接收并且另一端已关闭，则引发 EOFError”。

因此，我将示例修改为如下所示。恕我直言，这应该会触发 EOFError 异常：没有发送任何内容并且发送端已关闭。

修改后的代码：

from multiprocessing import Process, Pipe

def f(conn):
    #conn.send([42, None, 'hello'])
    conn.close()

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()
    p = Process(target=f, args=(child_conn,))
    p.start()
    #print parent_conn.recv()   # prints "[42, None, 'hello']"
    try:
        print parent_conn.recv()
    except EOFError:
        pass
    p.join()

但是，当我在我的 Ubuntu 11.04 机器 Python 2.7.2 上尝试修改后的示例时，脚本挂起。

如果有人能指出我错过了什么，我将不胜感激。

Answer 1

当您使用mp.Process 启动新进程时，子进程会继承父进程的管道。当子进程关闭conn时，父进程仍然有child_conn打开，因此管道文件描述符的引用计数仍然大于0，因此不会引发EOFError。

要获取 EOFError，请关闭父进程和子进程中的管道末端：

import multiprocessing as mp

def foo_pipe(conn):
    conn.close()

def pipe():
    conn = mp.Pipe()
    parent_conn, child_conn = conn
    proc = mp.Process(target = foo_pipe, args = (child_conn, ))
    proc.start()
    child_conn.close()  # <-- Close the child_conn end in the main process too.
    try:
        print(parent_conn.recv())
    except EOFError as err:
        print('Got here')
    proc.join()

if __name__=='__main__':
    pipe()