python - 关闭管道 python 子进程的标准输出

Question

这是我在 python 子进程模块文档中可以看到的内容:

Replacing shell pipeline

    output=`dmesg | grep hda`
    ==>
    p1 = Popen(["dmesg"], stdout=PIPE)
    p2 = Popen(["grep", "hda"], stdin=p1.stdout, stdout=PIPE)
    p1.stdout.close()  # Allow p1 to receive a SIGPIPE if p2 exits.
    output = p2.communicate()[0]

The p1.stdout.close() call after starting the p2 is important in order for p1
to receive a SIGPIPE if p2 exits before p1.

我真的不明白为什么我们必须在创建 p2 后关闭 p1.stdout。 p1.stdout.close() 什么时候执行？ 当 p2 永远不会结束时会发生什么？ 当 nor p1 或 p2 结束时会发生什么？

Answer 1

来自 Wikipedia , SIGPIPE 是当进程试图写入管道而另一端没有进程连接时发送给进程的信号。

当您第一次创建 p1 时使用 stdout=PIPE ，有一个进程连接到管道，这是你的 Python 进程，你可以使用 p1.stdout 读取输出。 .

当您创建 p2 时使用 stdin=p1.stdout现在有两个进程连接到管道 p1.stdout .

通常，当您在管道中运行进程时，您希望所有进程在任何进程结束时结束。为了自动发生这种情况，您需要关闭 p1.stdout所以p2.stdin是附加到该管道的唯一进程，如果 p2结束和p1将附加数据写入标准输出，它将收到 SIGPIPE，因为不再有任何进程附加到该管道。