python multiprocessing庫(kù)多任務(wù)處理-進(jìn)程學(xué)習(xí)筆記3
導(dǎo)入
import multiprocessing
multiprocessing對(duì)象
創(chuàng)建進(jìn)程對(duì)象(p)
直接創(chuàng)建
p = multiprocessing.Process(target,args,kwargs)
target:傳入線程函數(shù)
args:傳遞函數(shù)參數(shù)(沒有可忽略,傳遞加括號(hào),結(jié)束加逗號(hào))如args=(1,)
kwargs:指定函數(shù)傳參(字典)
以類創(chuàng)建(繼承)
例如:
class Task(multiprocessing.Process):
? ? def run(self):
? ? ? ? 需要運(yùn)行的代碼
(在類中定義的其他函數(shù)要在run(名字不能改)函數(shù)里才能運(yùn)行,啟動(dòng)同下)
線程對(duì)象(p)
p.start()啟動(dòng)線程
進(jìn)程間的通信
創(chuàng)建隊(duì)列
q = multiprocessing.Queue()
放入數(shù)據(jù)
q.put(要放入的數(shù)據(jù))
取出數(shù)據(jù)
q.get(True)阻塞(默認(rèn))
q.get(False)不阻塞
學(xué)習(xí)教程來源:BV1FS4y1v7CW
標(biāo)簽: