Python: 如何以非阻塞方式读取子进程的标准输出

Question

我正在尝试制作一个简单的 python 脚本来启动子进程并监视其标准输出。以下是代码片段：

process = subprocess.Popen([path_to_exe, os.path.join(temp_dir,temp_file)], stdout=subprocess.PIPE)
while True:   
    output=process.stdout.readline()
    print "test"

问题是脚本在 output=process.stdout.readline() 上挂起并且行 print "test" 仅在子进程终止后执行。

有没有办法读取标准输出并打印它而不必等待子进程终止？

我正在启动的子进程是一个 Windows 二进制文件，我没有它的源代码。

我发现了几个类似的问题，但答案仅适用于 Linux 或者如果我有我正在启动的 suprocess 的来源。

Answer 1

你可以试试这个：

import subprocess
import os

""" Continuously print command output """
""" Will only work if there are newline characters in the output. """

def run_cmd(command):    
    popen = subprocess.Popen(command, stdout=subprocess.PIPE)
    return iter(popen.stdout.readline, b"")

for line in run_cmd([path_to_exe, os.path.join(temp_dir,temp_file)]):
    print(line), # the comma keeps python from adding an empty line

Answer 2

检查select模块

import subprocess
import select
import time
    
x=subprocess.Popen(['/bin/bash','-c',"while true; do sleep 5; echo yes; done"],stdout=subprocess.PIPE)
    
y=select.poll()
y.register(x.stdout,select.POLLIN)

while True:
  if y.poll(1):
     print x.stdout.readline()
  else:
     print "nothing here"
     time.sleep(1)

编辑：

非 posix 系统的线程解决方案：

import subprocess
from threading import Thread 
import time
 
linebuffer=[]
x=subprocess.Popen(['/bin/bash','-c',"while true; do sleep 5; echo yes; done"],stdout=subprocess.PIPE)

def reader(f,buffer):
   while True:
     line=f.readline()
     if line:
        buffer.append(line)
     else:
        break

t=Thread(target=reader,args=(x.stdout,linebuffer))
t.daemon=True
t.start()

while True:
  if linebuffer:
     print linebuffer.pop(0)
  else:
     print "nothing here"
     time.sleep(1)

Python: 如何以非阻塞方式读取子进程的标准输出

Python: How to read stdout of subprocess in a nonblocking way

python

standards

subprocess

output

编辑：