如何防止Python程序在捕获连续进程输出时挂起？

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

当使用 os.popen() 捕获进程输出时，如果出现以下情况，程序可能会挂起：过程不断输出数据。要解决此问题，请考虑使用替代方法，例如：

使用子进程和线程

使用 subprocess.Popen 启动进程，创建一个线程来读取输出，并将其存储在队列中。在特定超时后终止进程。

<code class="python">import subprocess
import threading
import time

def read_output(process, append):
    for line in iter(process.stdout.readline, ""):
        append(line)

def main():
    process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)
    try:
        q = collections.deque(maxlen=200)
        t = threading.Thread(target=read_output, args=(process, q.append))
        t.daemon = True
        t.start()
        time.sleep(2)
    finally:
        process.terminate()
    print(''.join(q))</code>

使用信号处理程序

使用 signal.alarm() 在指定超时后引发异常。这会强制进程终止，从而捕获输出。

<code class="python">import signal
import subprocess
import time

def alarm_handler(signum, frame):
    raise Alarm

def main():
    process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)
    signal.signal(signal.SIGALRM, alarm_handler)
    signal.alarm(2)
    q = collections.deque(maxlen=200)
    try:
        for line in iter(process.stdout.readline, ""):
            q.append(line)
        signal.alarm(0)
    except Alarm:
        process.terminate()
    finally:
        print(''.join(q))</code>

使用计时器

使用线程。计时器在超时后终止进程。

<code class="python">import threading
import subprocess

def main():
    process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)
    timer = threading.Timer(2, process.terminate)
    timer.start()
    q = collections.deque(process.stdout, maxlen=200)
    timer.cancel()
    print(''.join(q))</code>

替代方法

• 临时文件：将进程输出临时存储到文件中，然后在进程结束后读取它
• 定期轮询：定期循环读取输出，直到进程终止。
• 非阻塞输出流：使用支持非阻塞输出流以避免挂起的库。

请注意，这些解决方案可能会引入额外的复杂性或兼容性问题。选择最适合您的特定需求和平台的方法。

以上是如何防止Python程序在捕获连续进程输出时挂起？的详细内容。更多信息请关注PHP中文网其他相关文章！