这是一个块缓冲问题。
以下是我对您的案例的回答的扩展版本Python:从 subprocess.communicate() 读取流输入 https://stackoverflow.com/a/17698359/4279问题。
直接在C程序中修复stdout缓冲区
stdio
通常,如果基于基于 的程序在终端中交互运行,则它们是行缓冲的;当它们的标准输出重定向到管道时,它们是块缓冲的。在后一种情况下,在缓冲区溢出或刷新之前您不会看到新行。
为了避免打电话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
还有其他可用的实用程序,请参阅关闭管道中的缓冲 https://unix.stackexchange.com/q/25372/1321.
或者使用伪 TTY
要欺骗子进程认为它正在交互运行,您可以使用pexpect module http://pexpect.readthedocs.org/en/latest/或其类似物,用于使用的代码示例pexpect
and pty
模块,参见Python 子进程 readlines() 挂起 https://stackoverflow.com/a/12471855/4279。这是一个变体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)
Or use pty
via pexpect
pexpect
wraps pty
处理成高层接口 http://pexpect.readthedocs.org/en/latest/overview.html:
#!/usr/bin/env python
import pexpect
child = pexpect.spawn("/.main")
for line in child:
print line,
child.close()
问:为什么不直接使用管道(popen())? http://pexpect.readthedocs.org/en/latest/FAQ.html#whynotpipe解释了为什么伪 TTY 很有用。