建站
咨詢
售后
建站咨詢
新聞中心
在python中大部分情況需要使用多進程，python提供了multiprocessing模塊。multiprocessing模塊的功能眾多：支持子進程、通信和共享數(shù)據(jù)、執(zhí)行不同形式的同步，提供了Process、Queue、Pipe、Lock等組件。本文將著重講解process模塊的使用
在翼城等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供網(wǎng)站制作、成都網(wǎng)站設計 網(wǎng)站設計制作定制網(wǎng)站設計,公司網(wǎng)站建設,企業(yè)網(wǎng)站建設,品牌網(wǎng)站制作,成都全網(wǎng)營銷,成都外貿(mào)網(wǎng)站建設公司,翼城網(wǎ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í)行了完了主進程的內(nèi)容')
# 輸出
這是主進程——>進程號： 3100 主進程號（pycharm）： 6748
執(zhí)行了完了主進程的內(nèi)容
這是一個子進程——>進程號： 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í)行了完了主進程的內(nèi)容')
# 輸出
這是主進程——>進程號： 11936 主進程號（pycharm）： 3676
執(zhí)行了完了主進程的內(nèi)容
這是一個子進程——>進程號： 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í)行了完了主進程的內(nèi)容')
# 輸出
這是主進程——>進程號： 12632 主進程號（pycharm）： 9220
執(zhí)行了完了主進程的內(nèi)容
這是一個子進程——>進程號：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（）內(nèi)部調用的原，使用if name == ‘main‘:，這個if語句中的語句將不會在導入時被調用。
以上就是python process模塊的使用簡介的詳細內(nèi)容。
分享名稱：python process模塊講解
文章分享：http://m.5511xx.com/article/dhoojhg.html
