Python實現多進程的四種方式
更新時間：2019年02月22日 08:58:44 作者：Money多多
今天小編就為大家分享一篇關于Python實現多進程的四種方式，小編覺得內容挺不錯的，現在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧
方式一: os.fork()
# -*- coding:utf-8 -*-
"""
pid=os.fork()
1.只用在Unix系統(tǒng)中有效，Windows系統(tǒng)中無效
2.fork函數調用一次，返回兩次：在父進程中返回值為子進程id，在子進程中返回值為0
"""
import os
pid=os.fork()
if pid==0:
print("執(zhí)行子進程，子進程pid={pid},父進程ppid={ppid}".format(pid=os.getpid(),ppid=os.getppid()))
else:
print("執(zhí)行父進程，子進程pid={pid},父進程ppid={ppid}".format(pid=pid,ppid=os.getpid()))
方式二: 使用multiprocessing模塊: 創(chuàng)建Process的實例，傳入任務執(zhí)行函數作為參數
# -*- coding:utf-8 -*-
"""
Process常用屬性與方法：
name:進程名
pid：進程id
run()，自定義子類時覆寫
start()，開啟進程
join(timeout=None)，阻塞進程
terminate(),終止進程
is_alive()，判斷進程是否存活
"""
import os,time
from multiprocessing import Process
def worker():
print("子進程執(zhí)行中>>> pid={0},ppid={1}".format(os.getpid(),os.getppid()))
time.sleep(2)
print("子進程終止>>> pid={0}".format(os.getpid()))
def main():
print("主進程執(zhí)行中>>> pid={0}".format(os.getpid()))
ps=[]
# 創(chuàng)建子進程實例
for i in range(2):
p=Process(target=worker,name="worker"+str(i),args=())
ps.append(p)
# 開啟進程
for i in range(2):
ps[i].start()
# 阻塞進程
for i in range(2):
ps[i].join()
print("主進程終止")
if __name__ == '__main__':
main()
方式三: 使用multiprocessing模塊: 派生Process的子類，重寫run方法
# -*- coding:utf-8 -*-
import os,time
from multiprocessing import Process
class MyProcess(Process):
def __init__(self):
Process.__init__(self)
def run(self):
print("子進程開始>>> pid={0},ppid={1}".format(os.getpid(),os.getppid()))
time.sleep(2)
print("子進程終止>>> pid={}".format(os.getpid()))
def main():
print("主進程開始>>> pid={}".format(os.getpid()))
myp=MyProcess()
myp.start()
# myp.join()
print("主進程終止")
if __name__ == '__main__':
main()
方式四: 使用進程池Pool
# -*- coding:utf-8 -*-
import os,time
from multiprocessing import Pool
def worker(arg):
print("子進程開始執(zhí)行>>> pid={},ppid={},編號{}".format(os.getpid(),os.getppid(),arg))
time.sleep(0.5)
print("子進程終止>>> pid={},ppid={},編號{}".format(os.getpid(),os.getppid(),arg))
def main():
print("主進程開始執(zhí)行>>> pid={}".format(os.getpid()))
ps=Pool(5)
for i in range(10):
# ps.apply(worker,args=(i,)) # 同步執(zhí)行
ps.apply_async(worker,args=(i,)) # 異步執(zhí)行
# 關閉進程池，停止接受其它進程
ps.close()
# 阻塞進程
ps.join()
print("主進程終止")
if __name__ == '__main__':
main()
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對腳本之家的支持。如果你想了解更多相關內容請查看下面相關鏈接
相關文章
這篇文章主要介紹了Python 文件處理注意事項總結的相關資料,需要的朋友可以參考下2017-04-04
這篇文章主要介紹了Python面向對象程序設計,結合實例形式總結分析了Python面向對象程序設計中比較常見的類定義、實例化、繼承、私有變量等相關使用技巧與操作注意事項,需要的朋友可以參考下2019-01-01
這篇文章主要介紹了Python中for后接else的語法使用，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-05-05
這篇文章主要介紹了如何使用Python 打印各種三角形，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-06-06
這篇文章主要介紹了Django給表單添加honeypot驗證增加安全性的方法，幫助大家更好的理解和學習使用Django框架，感興趣的朋友可以了解下2021-05-05
今天帶大家來學習python基礎知識,文中對python編碼規(guī)范作了詳細的介紹,對正在學習python的小伙伴們很有幫助,需要的朋友可以參考下2021-05-05
在VSCode中搭建Python開發(fā)環(huán)境并進行調試
這篇文章介紹了在VSCode中搭建Python開發(fā)環(huán)境并進行調試的方法，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-06-06
這篇文章主要介紹了使用Python的Zato發(fā)送AMQP消息的教程,主要是基于一些Zato的圖形化界面進行操作,需要的朋友可以參考下2015-04-04
這篇文章主要為大家詳細介紹了Python的閉包和裝飾器，何為閉包？何為裝飾器？感興趣的小伙伴們可以參考一下2016-02-02
這篇文章主要為大家詳細介紹了python數據結構之線性表的順序存儲結構，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-09-09