如何避免 Python 程式在讀取進程輸出時掛起？

停止讀取 Python 中的進程輸出而不掛起？

問題：

Python 程式需要與外部互動連續產生輸出的過程（例如「上」）。但是，直接讀取輸出可能會導致程式無限期掛起。

解決方案：

為了防止掛起，必須在以下情況下採用非阻塞或非同步機制：讀取過程輸出。以下是一些可能的方法：

假脫機暫存檔案（建議）

此方法利用專用檔案物件來儲存進程輸出。

#! /usr/bin/env python<br>導入子程序<br>導入臨時檔案<br>導入時間<p>def main():</p><pre class="brush:php;toolbar:false"># Open a temporary file (automatically deleted on closure)
f = tempfile.TemporaryFile()

# Start the process and redirect stdout to the file
p = subprocess.Popen(["top"], stdout=f)

# Wait for a specified duration
time.sleep(2)

# Kill the process
p.terminate()
p.wait()

# Rewind and read the captured output from the file
f.seek(0)
output = f.read()

# Print the output
print(output)
f.close()

if 名稱 == "__main__":

main()

基於執行緒的輸出讀取

這種方法採用單獨的執行緒來連續讀取進程輸出，同時主執行緒繼續執行其他任務。

導入集合<br>導入子程序<br>導入執行緒<br>導入時間<p>def read_output(process,append):</p><pre class="brush:php;toolbar:false">for line in iter(process.stdout.readline, ""):
    append(line)

def main():

# Start the process and redirect stdout
process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)

# Create a thread for output reading
q = collections.deque(maxlen=200)
t = threading.Thread(target=read_output, args=(process, q.append))
t.daemon = True
t.start()

# Wait for the specified duration
time.sleep(2)

# Print the saved output
print(''.join(q))

if 名稱

== "__main__":

main()

al.alarm ()（僅限Unix）

此方法使用Unix 訊號在指定逾時後終止進程，無論是否已讀取所有輸出。

導入集合<pre class="brush:php;toolbar:false">pass

導入訊號

導入子程序

raise Alarm

class Alarm(Exception):

# Start the process and redirect stdout
process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)

# Set signal handler
signal.signal(signal.SIGALRM, alarm_handler)
signal.alarm(2)

try:
    # Read and save a specified number of lines
    q = collections.deque(maxlen=200)
    for line in iter(process.stdout.readline, ""):
        q.append(line)
    signal.alarm(0)  # Cancel alarm
except Alarm:
    process.terminate()
finally:
    # Print the saved output
    print(''.join(q))

def Alarm_handler(signum,🎜>

def Alarm_handler(signum,,) :

main()

def main():

if

名稱

== "__main__":

== "__main__":

# Start the process and redirect stdout
process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)

# Create a timer for process termination
timer = threading.Timer(2, process.terminate)
timer.start()

# Read and save a specified number of lines
q = collections.deque(maxlen=200)
for line in iter(process.stdout.readline, ""):
    q.append(line)
timer.cancel()

# Print the saved output
print(''.join(q))

threading.Timer

此方法使用計時器在指定的逾時後終止程序。它適用於 Unix 和 Windows 系統。

導入集合<div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">main()

登入後複製

登入後複製