プロセス出力の読み取り時に Python プログラムがハングしないようにするにはどうすればよいですか?-Python チュートリアル-php.cn

プロセス出力の読み取り時に Python プログラムがハングしないようにするにはどうすればよいですか?

Susan Sarandon

リリース： 2024-11-02 13:54:29

オリジナル

530 人が閲覧しました

How to Avoid Python Programs from Hanging When Reading Process Output?

ハングせずに Python でのプロセス出力の読み取りを停止しますか?

問題:

Python プログラムは外部と対話する必要があります継続的に出力を生成するプロセス (「トップ」など)。ただし、出力を直接読み取るだけでは、プログラムが無期限にハングする可能性があります。

解決策:

ハングを防ぐには、次の場合に非ブロッキングまたは非同期メカニズムを採用することが不可欠です。読み取りプロセスの出力。以下に考えられるアプローチをいくつか示します。

スプール一時ファイル (推奨)

このメソッドは、専用のファイルオブジェクトを利用してプロセス出力を保存します。

#! /usr/bin/env python<br>import subprocess<br>import tempfile<br>import time</p>
<p>def main():</p>
<div class="code" style="position:relative; padding:0px; margin:0px;"><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()

ログイン後にコピー

このアプローチでは、別のスレッドを使用してプロセス出力を継続的に読み取ります。メインスレッドは他のタスクを続行します。

コレクションのインポート サブプロセスのインポート スレッドのインポート インポート時間 def read_output(process, append): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">for line in iter(process.stdout.readline, ""): append(line)

# 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))

インポートコレクション インポートシグナル インポートサブプロセス クラス Alarm(Exception): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">pass

# 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 main(): <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false"># 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))

args = sys.argv[1:] if not args: args = ['top'] # Start the process and redirect stdout process = subprocess.Popen(args, stdout=subprocess.PIPE, close_fds=True) # Save a specified number of lines q = collections.deque(maxlen=200) # Set a timeout duration timeout = 2 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 the saved output print(''.join(q))