在python的進程管理中我們一般使用process模塊進行python進程創(chuàng)建。這個模塊在使用上也是比較簡單的。那么python怎么使用process模塊來創(chuàng)建進程呢?接下來這篇文章帶你了解!
process模塊
process模塊是一個創(chuàng)建進程的模塊,借助這個模塊,就可以完成進程的創(chuàng)建。
參數(shù)介紹:
Process(group=None, target=None, name=None, args=(), kwargs={}) ? 1 group——參數(shù)未使用,值始終為None 2 target——表示調用對象,即子進程要執(zhí)行的任務 3 args——表示調用對象的位置參數(shù)元組,args=(1,2,'egon',) 4 kwargs——表示調用對象的字典,kwargs={'name':'egon','age':18} 5 name——為子進程的名稱
方法介紹:
obj.start():啟動進程,并調用該子進程中的obj.run() obj.run():進程啟動時運行的方法,正是它去調用target指定的函數(shù),我們自定義類的類中一定要實現(xiàn)該方法 obj.terminate():強制終止進程obj,不會進行任何清理操作,如果obj創(chuàng)建了子進程,該子進程就成了僵尸進程,使用該方法需要特別小心這種情況。如果obj還保存了一個鎖那么也將不會被釋放,進而導致死鎖 obj.is_alive():如果obj仍然運行,返回True obj.join([timeout]):主線程等待obj終止(強調:是主線程處于等的狀態(tài),而obj是處于運行的狀態(tài))。timeout是可選的超時時間,需要強調的是,obj.join只能join住start開啟的進程,而不能join住run開啟的進程
屬性介紹:
obj.daemon:默認值為False,如果設為True,代表obj為后臺運行的守護進程,當obj的父進程終止時,obj也隨之終止,并且設定為True后,obj不能創(chuàng)建自己的新進程,必須在obj.start()之前設置 obj.name:進程的名稱 obj.pid:進程的pid obj.exitcode:進程在運行時為None、如果為–N,表示被信號N結束(了解即可) obj.authkey:進程的身份驗證鍵,默認是由os.urandom()隨機生成的32字符的字符串。這個鍵的用途是為涉及網(wǎng)絡連接的底層進程間通信提供安全性,這類連接只有在具有相同的身份驗證鍵時才能成功(了解即可)
1、在python中啟動一個子進程
from multiprocessing import Process import os ? def func(): print('這是一個子進程——>進程號:', os.getpid(), ' 主進程號:', os.getppid()) ? ? if __name__ == '__main__': print('這是主進程——>進程號:', os.getpid(), ' 主進程號(pycharm):', os.getppid()) # 實例化一個子進程對象 obj = Process(target=func) obj.start() # 執(zhí)行子進程對象 print('執(zhí)行了完了主進程的內容') ? # 輸出 這是主進程——>進程號: 3100 主進程號(pycharm): 6748 執(zhí)行了完了主進程的內容 這是一個子進程——>進程號: 2392 主進程號: 3100
2、給子進程傳遞參數(shù)
from multiprocessing import Process import os ? ? def func(name, age): print('這是一個子進程——>進程號:', os.getpid(), ' 主進程號:', os.getppid()) print(f'這是一個子進程——>我的名字是{name},今年{age}') ? ? if __name__ == '__main__': print('這是主進程——>進程號:', os.getpid(), ' 主進程號(pycharm):', os.getppid()) # 實例化一個子進程對象 obj = Process(target=func, args=('小楊', '18')) # args以元組的形式給子進程func函數(shù)傳位置參數(shù) # kwargs以字典的形式給子進程func函數(shù)傳關鍵字參數(shù) # kwargs={'name': '小楊', 'age': 18} obj.start() # 執(zhí)行子進程對象 print('執(zhí)行了完了主進程的內容') # 輸出 這是主進程——>進程號: 11936 主進程號(pycharm): 3676 執(zhí)行了完了主進程的內容 這是一個子進程——>進程號: 2996 主進程號: 11936 這是一個子進程——>我的名字是小楊,今年18
3、同時開多個子進程
from multiprocessing import Process import os ? ? def func(name, age): print(f'這是一個子進程——>進程號:{os.getpid()},主進程號:{os.getppid()},我的名字是{name},今年{age}') ? ? if __name__ == '__main__': print('這是主進程——>進程號:', os.getpid(), ' 主進程號(pycharm):', os.getppid()) count = [('小楊', 18), ('鮑勃', 20), ('艾倫', 55)] for lis in count: # 實例化一個子進程對象 obj = Process(target=func, args=lis) # args以元組的形式給子進程func函數(shù)傳位置參數(shù) obj.start() # 執(zhí)行子進程對象 print('執(zhí)行了完了主進程的內容') # 輸出 這是主進程——>進程號: 12632 主進程號(pycharm): 9220 執(zhí)行了完了主進程的內容 這是一個子進程——>進程號:10048,主進程號:12632,我的名字是小楊,今年18 這是一個子進程——>進程號:16032,主進程號:12632,我的名字是鮑勃,今年20 這是一個子進程——>進程號:12060,主進程號:12632,我的名字是艾倫,今年55
4、join的用法
obj.join([timeout]): 主進程等待子進程obj終止(強調:是主進程處于等的狀態(tài),而子進程obj是處于運行的狀態(tài))。timeout是可選的超時時間,需要強調的是,obj.join只能join住start開啟的進程,而不能join住run開啟的進程
多個進程同時運行(注意,子進程的執(zhí)行順序不是根據(jù)啟動順序決定的)
join——>屬于同步阻塞:
同步:在做A事件的時候發(fā)起B(yǎng)事件,必須等待B事件結束后才能繼續(xù)做A事件
阻塞:CPU不工作——>input accept recv recvfrom sleep connect......
start——>屬于異步非阻塞:
異步:在做A事件的時候發(fā)起B(yǎng)事件,不用等待B事件結束就可以繼續(xù)A事件
非阻塞:CPU在工作(非輸入輸出階段I/O)
from multiprocessing import Process import random import time ? ? def mail(name, age): count = random.random() print(f'給{age}歲的{name}發(fā)了一封郵件!延遲{count}秒') time.sleep(count) # 模擬網(wǎng)絡延遲 """ 多個進程同時運行(注意,子進程的執(zhí)行順序不是根據(jù)啟動順序決定的) """ ? ? if __name__ == '__main__': info_list = [('小楊', 18), ('鮑勃', 20), ('艾倫', 55)] jo = [] for info in info_list: obj = Process(target=mail, args=info) obj.start() jo.append(obj) ? # 將所有的子進程全部放入jo列表,在循環(huán)join所有子進程,就能等待所有子進程結束后在做操作 for o in jo: o.join() ? # 所有的子進程結束的操作 print('全部發(fā)送完畢') # 輸出 給20歲的鮑勃發(fā)了一封郵件!延遲0.19840279388911186秒 給18歲的小楊發(fā)了一封郵件!延遲0.8891892863366903秒 給55歲的艾倫發(fā)了一封郵件!延遲0.0434307277609951秒 全部發(fā)送完畢
5、多進程之間的數(shù)據(jù)是否隔離
from multiprocessing import Process ? count = 1 ? def func(): global count count += 1 ? if __name__ == '__main__': for i in range(10): obj = Process(target=func) obj.start() print(count) # ————>1 主進程的count沒有被改變說明進程之間的數(shù)據(jù)時隔離的 # 輸出 1
6、為什么在Windows中Process()必須放到if __name__ == '__main__':下
由于Windows沒有fork,多處理模塊啟動一個新的Python進程并導入調用模塊。
如果在導入時調用Process(),那么這將啟動無限繼承的新進程(或直到機器耗盡資源)。
這是隱藏對Process()內部調用的原,使用if __name__ == '__main__':,這個if語句中的語句將不會在導入時被調用。
以上就是python怎么使用process模塊來創(chuàng)建進程的詳細內容,更多python的學習資料請關注W3Cschool其它相關文章!