Python多進(jìn)程編程常用方法解析
更新時(shí)間：2020年03月26日 11:14:55 作者：Python熱愛者
這篇文章主要介紹了Python多進(jìn)程編程常用方法解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
python中的多線程其實(shí)并不是真正的多線程，如果想要充分地使用多核CPU資源，在python中大部分情況需要使用多進(jìn)程。python提供了非常好用的多進(jìn)程包Multiprocessing，只需要定義一個(gè)函數(shù)，python會(huì)完成其它所有事情。借助這個(gè)包，可以輕松完成從單進(jìn)程到并發(fā)執(zhí)行的轉(zhuǎn)換。multiprocessing支持子進(jìn)程、通信和共享數(shù)據(jù)、執(zhí)行不同形式的同步，提供了Process、Queue、Pipe、LocK等組件
一、Process
語(yǔ)法：Process([group[,target[,name[,args[,kwargs]]]]])
參數(shù)含義：target表示調(diào)用對(duì)象；args表示調(diào)用對(duì)象的位置參數(shù)元祖；kwargs表示調(diào)用對(duì)象的字典。name為別名，groups實(shí)際上不會(huì)調(diào)用。
方法：is_alive()：
join(timeout)：
run()：
start()：
terminate()：
屬性：authkey、daemon(要通過start()設(shè)置)、exitcode(進(jìn)程在運(yùn)行時(shí)為None、如果為-N，表示被信號(hào)N結(jié)束)、name、pid。其中daemon是父進(jìn)程終止后自動(dòng)終止，且自己不能產(chǎn)生新的進(jìn)程，必須在start()之前設(shè)置。
1.創(chuàng)建函數(shù)，并將其作為單個(gè)進(jìn)程
from multiprocessing import Process
def func(name):
print("%s曾經(jīng)是好人"%name)
if __name__ == "__main__":
p = Process(target=func,args=('kebi',))
p.start() #start()通知系統(tǒng)開啟這個(gè)進(jìn)程
2.創(chuàng)建函數(shù)并將其作為多個(gè)進(jìn)程
from multiprocessing import Process
import random,time
def hobby_motion(name):
print('%s喜歡運(yùn)動(dòng)'% name)
time.sleep(random.randint(1,3))
def hobby_game(name):
print('%s喜歡游戲'% name)
time.sleep(random.randint(1,3))
if __name__ == "__main__":
p1 = Process(target=hobby_motion,args=('付婷婷',))
p2 = Process(target=hobby_game,args=('科比',))
p1.start()
p2.start()
執(zhí)行結(jié)果：
付婷婷喜歡運(yùn)動(dòng)
科比喜歡游戲
3.將進(jìn)程定義為類（開啟進(jìn)程的另一種方法，并不是很常用）
from multiprocessing import Process
class MyProcess(Process):
def __init__(self,name):
super().__init__()
self.name = name
def run(self): #start()時(shí)，run自動(dòng)調(diào)用，而且此處只能定義為run。
print("%s曾經(jīng)是好人"%self.name)
if __name__ == "__main__":
p = MyProcess('kebi')
p.start() #將Process當(dāng)作父類，并且自定義一個(gè)函數(shù)。
4.daemon程序?qū)Ρ刃Ч?/strong>
不加daemon屬性
import time
def func(name):
print("work start:%s"% time.ctime())
time.sleep(2)
print("work end:%s"% time.ctime())
if __name__ == "__main__":
p = Process(target=func,args=('kebi',))
p.start()
print("this is over")
#執(zhí)行結(jié)果
this is over
work start:Thu Nov 30 16:12:00 2017
work end:Thu Nov 30 16:12:02 2017
加上daemon屬性
from multiprocessing import Process
import time
def func(name):
print("work start:%s"% time.ctime())
time.sleep(2)
print("work end:%s"% time.ctime())
if __name__ == "__main__":
p = Process(target=func,args=('kebi',))
p.daemon = True #父進(jìn)程終止后自動(dòng)終止，不能產(chǎn)生新進(jìn)程，必須在start()之前設(shè)置
p.start()
print("this is over")
#執(zhí)行結(jié)果
this is over
設(shè)置了daemon屬性又想執(zhí)行完的方法：
import time
def func(name):
print("work start:%s"% time.ctime())
time.sleep(2)
print("work end:%s"% time.ctime())
if __name__ == "__main__":
p = Process(target=func,args=('kebi',))
p.daemon = True
p.start()
p.join() #執(zhí)行完前面的代碼再執(zhí)行后面的
print("this is over")
#執(zhí)行結(jié)果
work start:Thu Nov 30 16:18:39 2017
work end:Thu Nov 30 16:18:41 2017
this is over
5.join()：上面的代碼執(zhí)行完畢之后，才會(huì)執(zhí)行后i面的代碼。
先看一個(gè)例子：
from multiprocessing import Process
import time,os,random
def func(name,hour):
print("A lifelong friend:%s,%s"% (name,os.getpid()))
time.sleep(hour)
print("Good bother:%s"%name)
if __name__ == "__main__":
p = Process(target=func,args=('kebi',2))
p1 = Process(target=func,args=('maoxian',1))
p2 = Process(target=func,args=('xiaoniao',3))
p.start()
p1.start()
p2.start()
print("this is over")
執(zhí)行結(jié)果：
this is over #最后執(zhí)行，最先打印，說明start()只是開啟進(jìn)程，并不是說一定要執(zhí)行完
A lifelong friend:kebi,12048
A lifelong friend:maoxian,8252
A lifelong friend:xiaoniao,6068
Good bother:maoxian #最先打印，第二位執(zhí)行
Good bother:kebi
Good bother:xiaoniao
添加join（）
from multiprocessing import Process
import time,os,random
def func(name,hour):
print("A lifelong friend:%s,%s"% (name,os.getpid()))
time.sleep(hour)
print("Good bother:%s"%name)
start = time.time()
if __name__ == "__main__":
p = Process(target=func,args=('kebi',2))
p1 = Process(target=func,args=('maoxian',1))
p2 = Process(target=func,args=('xiaoniao',3))
p.start()
p.join() #上面的代碼執(zhí)行完畢之后，再執(zhí)行后面的
p1.start()
p1.join()
p2.start()
p2.join()
print("this is over")
print(time.time() - start)
#執(zhí)行結(jié)果
A lifelong friend:kebi,14804
Good bother:kebi
A lifelong friend:maoxian,11120
Good bother:maoxian
A lifelong friend:xiaoniao,10252 #每個(gè)進(jìn)程執(zhí)行完了，才會(huì)執(zhí)行下一個(gè)
Good bother:xiaoniao
this is over
6.497815370559692 #2+1+3+主程序執(zhí)行時(shí)間
改變一下位置
from multiprocessing import Process
import time,os,random
def func(name,hour):
print("A lifelong friend:%s,%s"% (name,os.getpid()))
time.sleep(hour)
print("Good bother:%s"%name)
start = time.time()
if __name__ == "__main__":
p = Process(target=func,args=('kebi',2))
p1 = Process(target=func,args=('maoxian',1))
p2 = Process(target=func,args=('xiaoniao',3))
p.start()
p1.start()
p2.start()
p.join() #需要2秒
p1.join() #到這時(shí)已經(jīng)執(zhí)行完
p2.join() #已經(jīng)執(zhí)行了2秒，還要1秒
print("this is over")
print(time.time() - start)
#執(zhí)行結(jié)果
A lifelong friend:kebi,13520
A lifelong friend:maoxian,11612
A lifelong friend:xiaoniao,17064 #幾乎是同時(shí)開啟執(zhí)行
Good bother:maoxian
Good bother:kebi
Good bother:xiaoniao
this is over
3.273620367050171 #以最長(zhǎng)時(shí)間的為主
6.其它屬性和方法
from multiprocessing import Process
import time
def func(name):
print("work start:%s"% time.ctime())
time.sleep(2)
print("work end:%s"% time.ctime())
if __name__ == "__main__":
p = Process(target=func,args=('kebi',))
p.start()
p.terminate() #將進(jìn)程殺死，而且必須放在start()后面，與daemon的功能類似
#執(zhí)行結(jié)果
this is over
from multiprocessing import Process
import time
def func(name):
print("work start:%s"% time.ctime())
time.sleep(2)
print("work end:%s"% time.ctime())
if __name__ == "__main__":
p = Process(target=func,args=('kebi',))
# p.daemon = True
print(p.is_alive())
p.start()
print(p.name) #獲取進(jìn)程的名字
print(p.pid) #獲取進(jìn)程的pid
print(p.is_alive()) #判斷進(jìn)程是否存在
print("this is over")
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:
- python并發(fā)編程之多進(jìn)程、多線程、異步和協(xié)程詳解
- 深入淺析python中的多進(jìn)程、多線程、協(xié)程
- python學(xué)習(xí)筆記之多進(jìn)程
- python多進(jìn)程 主進(jìn)程和子進(jìn)程間共享和不共享全局變量實(shí)例
- Python多進(jìn)程multiprocessing、進(jìn)程池用法實(shí)例分析
- python3爬蟲中異步協(xié)程的用法
- Python手動(dòng)或自動(dòng)協(xié)程操作方法解析
- 淺談Python協(xié)程
- python 使用事件對(duì)象asyncio.Event來同步協(xié)程的操作
- python 多進(jìn)程和協(xié)程配合使用寫入數(shù)據(jù)
相關(guān)文章
這篇文章主要介紹了淺談Python traceback的優(yōu)雅處理，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-08-08
Python入門Anaconda和Pycharm的安裝和配置詳解
這篇文章主要介紹了Python入門Anaconda和Pycharm的安裝和配置詳解，文章通過圖文介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-07-07
這篇文章主要為大家詳細(xì)介紹了Python實(shí)現(xiàn)雙向鏈表基本操作，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-05-05
在Python中輸入一個(gè)以空格為間隔的數(shù)組方法
今天小編就為大家分享一篇在Python中輸入一個(gè)以空格為間隔的數(shù)組方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-11-11
python中pandas.read_csv()函數(shù)的深入講解
這篇文章主要給大家介紹了關(guān)于python中pandas.read_csv()函數(shù)的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
解決pycharm安裝scrapy DLL load failed:找不到指定的程序的問題
很多朋友向小編求助pycharm安裝scrapy DLL load failed:找不到指定的程序的問題，就這一問題小編在window10 + anaconda3 +pycharm2020.1.1 + scrapy安裝親測(cè)可用，下面把我的處理過程分享到腳本之家平臺(tái)，供大家參考2021-06-06
Python實(shí)現(xiàn)確認(rèn)字符串是否包含指定字符串的實(shí)例
下面小編就為大家分享一篇Python實(shí)現(xiàn)確認(rèn)字符串是否包含指定字符串的實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-05-05
python如何使用requests提交post請(qǐng)求并上傳文件(multipart/form-data)
這篇文章主要給大家介紹了關(guān)于python如何使用requests提交post請(qǐng)求并上傳文件(multipart/form-data)的相關(guān)資料,Python有許多庫(kù)支持,它們可以簡(jiǎn)化HTTP上的數(shù)據(jù)傳輸,requests庫(kù)是最受歡迎的Python包之一,因?yàn)樗诰W(wǎng)絡(luò)刮削中被大量使用,需要的朋友可以參考下2023-11-11
這篇文章主要介紹了淺析Python中的for 循環(huán)的相關(guān)資料,非常不錯(cuò)，具有參考借鑒價(jià)值，需要的朋友可以參考下2016-06-06
這篇文章主要介紹了Python運(yùn)算符重載用法,實(shí)例分析了幾種常見的Python運(yùn)算符重載的使用技巧,需要的朋友可以參考下2015-06-06