Python中subprocess.Popen子進程管道阻塞的示例分析

這篇文章主要為大家展示了“Python中subprocess.Popen子進程管道阻塞的示例分析”，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“Python中subprocess.Popen子進程管道阻塞的示例分析”這篇文章吧。

問題產生描述

使用子進程處理一個大的日志文件，并對文件進行分析查詢，需要等待子進程執行的輸出結果，進行下一步處理。

出問題的代碼

# 啟用子進程執行外部shell命令
def __subprocess(self,cmd):
 try:
 # 執行外部shell命令， 輸出結果輸出管道
 p = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) 
 p.wait()

 # 從標準輸出讀出shell命令的輸出結果
 #rt = p.stdout.read().decode()

 # 以換行符拆分數據，并去掉換行符號存入列表
 rt_list = rt.strip().split('\n')

 except Exception as e:
 if(DEBUG):
  print(traceback.format_exc())

 return rt_list

問題分析

子進程產生一些數據，他們會被buffer起來，當buffer滿了，會寫到子進程的標準輸出和標準錯誤輸出，這些東西通過管道發送給父進程。當管道滿了之后，子進程就停止寫入，于是就卡住了，及時取走管道的輸出就不會出現阻塞了

但是本人此處采取的是臨時文件接收子進程輸出，由于臨時文件是建立在磁盤上的，沒有size的限制，并且文件被close后，相應的磁盤上的空間也會被釋放掉。

已改進的代碼

import tempfile
# 啟用子進程執行外部shell命令
def __subprocess(self,cmd):
 try:
 # 得到一個臨時文件對象， 調用close后，此文件從磁盤刪除
 out_temp = tempfile.TemporaryFile(mode='w+')
 # 獲取臨時文件的文件號
 fileno = out_temp.fileno()

 # 執行外部shell命令， 輸出結果存入臨時文件中
 p = subprocess.Popen(cmd, shell=True, stdout=fileno, stderr=fileno) 
 p.wait()

 # 從臨時文件讀出shell命令的輸出結果
 out_temp.seek(0)
 rt = out_temp.read()

 # 以換行符拆分數據，并去掉換行符號存入列表
 rt_list = rt.strip().split('\n')

 except Exception as e:
 if(DEBUG):
  print(traceback.format_exc())

 finally:
 if out_temp:
  out_temp.close()

 return rt_list

以上是“Python中subprocess.Popen子進程管道阻塞的示例分析”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！