Python C 程序子进程挂起在“for line in iter”处

问题描述：

好的，我正在尝试从 Python 脚本运行 C 程序。目前我正在使用测试 C 程序：

#include <stdio.h>

int main() {
    while (1) {
        printf("2000
");
        sleep(1);
    }
    return 0;
}

"2000"为了模拟我将要使用的程序，该程序会不断从传感器读取读数。然后，我尝试使用 python 中的子进程从 C 程序读取输出（在本例中）：

#!usr/bin/python
import subprocess

process = subprocess.Popen("./main", stdout=subprocess.PIPE)
while True:
    for line in iter(process.stdout.readline, ''):
            print line,

但这不起作用。通过使用 print 语句，它会运行该.Popen行，然后在 处等待for line in iter(process.stdout.readline, ''):，直到我按下 Ctrl-C。

这是为什么？这正是我见过的大多数示例的代码，但它却没有读取文件。

有没有办法让它仅在有内容需要读取时运行？

解决方案 1：

这是一个块缓冲问题。

接下来是我对Python：从 subprocess.communicate() 读取流输入问题的答案的扩展版本。

直接修复 C 程序中的 stdout 缓冲区

stdio基于 的程序通常在终端中交互运行时进行行缓冲，当其 stdout 重定向到管道时进行块缓冲。在后一种情况下，您不会看到新行，直到缓冲区溢出或刷新。

为了避免每次调用fflush()后都调用printf()，您可以在最开始的地方调用 C 程序来强制行缓冲输出：

setvbuf(stdout, (char *) NULL, _IOLBF, 0); /* make line buffered stdout */

在这种情况下，一旦打印出换行符，缓冲区就会被刷新。

或者在不修改 C 程序源代码的情况下修复它

有stdbuf一个实用程序允许您更改缓冲类型而无需修改源代码，例如：

from subprocess import Popen, PIPE

process = Popen(["stdbuf", "-oL", "./main"], stdout=PIPE, bufsize=1)
for line in iter(process.stdout.readline, b''):
    print line,
process.communicate() # close process' stream, wait for it to exit

还有其他可用的实用程序，请参阅关闭管道中的缓冲。

或者使用伪TTY

要诱使子进程认为它正在以交互方式运行，可以使用pexpect模块或其类似物，有关使用pexpect和pty模块的代码示例，请参阅Python subprocess readlines() hangs。这是那里提供的示例的变体pty（它应该在 Linux 上运行）：

#!/usr/bin/env python
import os
import pty
import sys
from select import select
from subprocess import Popen, STDOUT

master_fd, slave_fd = pty.openpty()  # provide tty to enable line buffering
process = Popen("./main", stdin=slave_fd, stdout=slave_fd, stderr=STDOUT,
                bufsize=0, close_fds=True)
timeout = .1 # ugly but otherwise `select` blocks on process' exit
# code is similar to _copy() from pty.py
with os.fdopen(master_fd, 'r+b', 0) as master:
    input_fds = [master, sys.stdin]
    while True:
        fds = select(input_fds, [], [], timeout)[0]
        if master in fds: # subprocess' output is ready
            data = os.read(master_fd, 512) # <-- doesn't block, may return less
            if not data: # EOF
                input_fds.remove(master)
            else:
                os.write(sys.stdout.fileno(), data) # copy to our stdout
        if sys.stdin in fds: # got user input
            data = os.read(sys.stdin.fileno(), 512)
            if not data:
                input_fds.remove(sys.stdin)
            else:
                master.write(data) # copy it to subprocess' stdin
        if not fds: # timeout in select()
            if process.poll() is not None: # subprocess ended
                # and no output is buffered <-- timeout + dead subprocess
                assert not select([master], [], [], 0)[0] # race is possible
                os.close(slave_fd) # subproces don't need it anymore
                break
rc = process.wait()
print("subprocess exited with status %d" % rc)

或者pty使用pexpect

pexpect将pty处理包装到更高级别的接口中：

#!/usr/bin/env python
import pexpect

child = pexpect.spawn("/.main")
for line in child:
    print line,
child.close()

问：为什么不直接使用管道 (popen())？解释了为什么伪 TTY 很有用。

解决方案 2：

您的程序没有挂起，只是运行速度非常慢。您的程序正在使用缓冲输出；数据`"2000
"不会立即写入 stdout，但最终会写入。就您而言，可能需要BUFSIZ/strlen("2000
")`几秒（可能是 1638 秒）才能完成。

在此行之后：

printf("2000
");

添加

fflush(stdout);

解决方案 3：

参见readline 文档。

您的代码：

process.stdout.readline

正在等待 EOF 或换行符。

我不知道您最终想要做什么，但是在 printf 中添加换行符（例如`printf("2000
");`）至少可以帮助您开始。