停止读取Python中的进程输出而不挂起？

#!/usr/bin/env python"""Start process; wait 2 seconds; kill the process; print all process output."" "import subprocessimport tempfileimport timedef main():     # open temporary file (it automatically deleted when it is closed)     #  `Popen` requires `f.fileno()` so `SpooledTemporaryFile` adds nothing here     f = tempfile.TemporaryFile()      # start process, redirect stdout     p = subprocess.Popen(["top"], stdout=f)     # wait 2 seconds     time.sleep(2)     # kill process     #NOTE: if it doesn't kill the process then `p.wait()` blocks forever     p.terminate()      p.wait() # wait for the process to terminate otherwise the output is garbled     # print saved output     f.seek(0) # rewind to the beginning of the file     print f.read(),      f.close()if __name__=="__main__":     main()只打印输出部分的类似尾部的解决方案您可以在另一个线程中读取进程输出，并在队列中保存所需的最后一行数：import collectionsimport subprocessimport timeimport threadingdef read_output(process, append):     for line in iter(process.stdout.readline, ""):         append(line)def main():     # start process, redirect stdout     process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)     try:         # save last `number_of_lines` lines of the process output         number_of_lines = 200         q = collections.deque(maxlen=number_of_lines) # atomic .append()         t = threading.Thread(target=read_output, args=(process, q.append))         t.daemon = True         t.start()         #         time.sleep(2)     finally:         process.terminate() #NOTE: it doesn't ensure the process termination     # print saved lines     print ''.join(q)if __name__=="__main__":     main()这个变体需要q.append()成为原子操作。否则，输出可能损坏。signal.alarm()解你可以用signal.alarm()调用process.terminate()在指定超时后，而不是在另一个线程中读取。虽然它可能与subprocess模块。基于@Alex Martelli的回答:import collectionsimport signalimport subprocessclass Alarm(Exception):     passdef alarm_handler(signum, frame):     raise Alarmdef main():     # start process, redirect stdout     process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)     # set signal handler     signal.signal(signal.SIGALRM, alarm_handler)     signal.alarm(2) # produce SIGALRM in 2 seconds     try:         # save last `number_of_lines` lines of the process output         number_of_lines = 200         q = collections.deque(maxlen=number_of_lines)         for line in iter(process.stdout.readline, ""):             q.append(line)         signal.alarm(0) # cancel alarm     except Alarm:         process.terminate()     finally:         # print saved lines         print ''.join(q)if __name__=="__main__":     main()这种方法只适用于*nix系统。如果process.stdout.readline()不会再回来了。threading.Timer解import collectionsimport subprocessimport threadingdef main():     # start process, redirect stdout     process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)     # terminate process in timeout seconds     timeout = 2 # seconds     timer = threading.Timer(timeout, process.terminate)     timer.start()     # save last `number_of_lines` lines of the process output     number_of_lines = 200     q = collections.deque(process.stdout, maxlen=number_of_lines)     timer.cancel()     # print saved lines     print ''.join(q),if __name__=="__main__":     main()这种方法也应该适用于Windows。我用过process.stdout作为一个可迭代的；它可能会引入一个额外的输出缓冲，您可以切换到iter(process.stdout.readline, "")如果这是不可取的，就接近它。如果进程未在process.terminate()然后脚本挂起。没有线程，没有信号解决方案import collectionsimport subprocessimport sysimport timedef main():     args = sys.argv[1:]     if not args:         args = ['top']     # start process, redirect stdout     process = subprocess.Popen(args, stdout=subprocess.PIPE, close_fds=True)     # save last `number_of_lines` lines of the process output     number_of_lines = 200     q = collections.deque(maxlen=number_of_lines)     timeout = 2 # seconds     now = start = time.time()         while (now - start) < timeout:         line = process.stdout.readline()         if not line:             break         q.append(line)         now = time.time()     else: # on timeout         process.terminate()     # print saved lines     print ''.join(q),if __name__=="__main__":     main()这个变体既不使用线程，也不使用信号，但它在终端中产生错误的输出。如果process.stdout.readline()街区。

停止读取Python中的进程输出而不挂起？

3回答