import multiprocessing as mp
from multiprocessing import Process
class MyProcess(Process):
    """
    自定義多進(jìn)程，繼承自原生Process,目的是獲取多進(jìn)程結(jié)果到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()  # 隊(duì)列,將多進(jìn)程結(jié)果存入這里，進(jìn)程間共享， 多進(jìn)程必須使用  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
    
 使用時(shí)候，將需要多進(jìn)程執(zhí)行的函數(shù)和函數(shù)的參數(shù)當(dāng)作字段，組成個(gè)list 傳給use_multiprocessing 方法即可

當(dāng)前名稱：python多進(jìn)程使用函數(shù)封裝
新聞來源：http://jinyejixie.com/article4/pgggie.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供營銷型網(wǎng)站建設(shè)、建站公司、面包屑導(dǎo)航、外貿(mào)建站、ChatGPT、定制網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)