溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
import multiprocessing as mp
from multiprocessing import Process
class MyProcess(Process):
"""
自定義多進程，繼承自原生Process,目的是獲取多進程結果到queue
"""
def __init__(self, func, args, q):
super(MyProcess, self).__init__()
self.func = func
self.args = args
self.res = ''
self.q = q
#self._daemonic = True
#self._daemonic = True
def run(self):
self.res = self.func(*self.args)
self.q.put((self.func.__name__, self.res))
def use_multiprocessing(func_list):
#os.system('export PYTHONOPTIMIZE=1') # 解決 daemonic processes are not allowed to have children 問題
q = mp.Queue() # 隊列,將多進程結果存入這里，進程間共享， 多進程必須使用 multiprocessing 的queue
proc_list = []
res = []
for func in func_list:
proc = MyProcess(func['func'], args=func['args'], q=q)
proc.start()
proc_list.append(proc)
for p in proc_list:
p.join()
while not q.empty():
r = q.get()
res.append(r)
return res
使用時候，將需要多進程執行的函數和函數的參數當作字段，組成個list 傳給use_multiprocessing 方法即可免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
