1. 程式人生 > 程式設計 >Python基於程序池實現多程序過程解析

Python基於程序池實現多程序過程解析

1、注意:pool必須在 if __name__ == '__main__' 下面執行,不然會報錯

2、多程序內出現錯誤會直接跳過該程序,並且預設不會列印錯誤資訊

3、if__name__下面的資料需要通過引數傳入主函式裡面,不然主函式獲取不到該資料值而報錯。

4、若不通過傳參形式傳入資料,可以定義全域性變數。但是全域性變數的值不能在多程序裡面進行修改。

程式碼如下

from multiprocessing import Pool # 程序池,用於多程序
import os # 用於獲取當前執行的檔名
import time
import traceback # 用於捕獲異常
import sys # 用於捕獲異常


def main_func(i): # 多程序執行的函式
  try: # 多程序中發生異常是不會列印錯誤資訊,並且當前程序會直接跳過,所以異常需要自行捕獲
    rand_time = random.randint(1,3) # 隨機產生1~3的整數
    time.sleep(rand_time )
    print(i)
  except:
    current_filename = str(os.path.basename(sys.argv[0]))[:-3] # 獲取當前檔名稱
    cur_err_filname = current_filename + '_error.txt'
    error_info = sys.exc_info() # 列印異常
    with open(f'{cur_err_filname }','a') as f:
      error_str = f'{i}:ERROR OCCURRED,{time.strftime("%Y-%m-%d %H:%M:%S")}:\n {error_info[0]}: {error_info[1]}' # 記錄當前程序特徵值,錯誤發生時間 ,錯誤型別,錯誤概述
      print(error_str,file=f) # 通過列印方式寫入檔案
      traceback.print_tb(error_info[2],file=f) # 錯誤細節描述(包括bug的程式碼位置)
      f.write(f"{'=' * 50}\n") # 分行


if __name__ == '__main__': # 必須在此語句下面執行,不然會報錯
  pool = Pool(5) # 定義程序數量
  for i in range(20):
    pool.apply_async(main_func,(i,)) # 呼叫函式執行多程序
  pool.close() # 關閉程序池
  pool.join() # 阻塞程序,此兩部不能少,保證多程序正常執行

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。