亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Python多進程入門、分布式進程數(shù)據(jù)共享實例詳解

系統(tǒng) 1528 0

本文實例講述了Python多進程入門、分布式進程數(shù)據(jù)共享。分享給大家供大家參考,具體如下:

python多進程入門

https://docs.python.org/3/library/multiprocessing.html

1、先來個簡單的

            
# coding: utf-8
from multiprocessing import Process
# 定義函數(shù)
def addUser():
  print("addUser")
if __name__ == "__main__":
  p1 = Process(target=addUser)
  p1.start()


          

多進程包 multiprocessing
創(chuàng)建進程 p1 = Process(target=函數(shù)名) ;
開始進程 p1.start()

2、通過進程ID來區(qū)分父子進程

            
# coding: utf-8
from multiprocessing import Process
import os
# 定義一個list
myList = ["a","b"];
# 定義函數(shù)
def addUser(list):
  print(os.getpid()) # 進程ID
  print(os.getppid()) # 父進程ID
if __name__ == "__main__":
  p1 = Process(target=addUser,args=(myList,))
  p1.start()
  # 這里是主進程
  print("父進程ID:"+str(os.getpid())) # 進程ID


          

父進程ID:27084
27085
27084

3、主進程等等子進程執(zhí)行完畢

            
# 定義一個list
myList = ["a","b"];
# 定義函數(shù)
def addUser(list):
  list.append("c")
  print(list)
if __name__ == "__main__":
  p1 = Process(target=addUser,args=(myList,))
  p1.start()
  print(myList)


          

['a', 'b']
['a', 'b', 'c']

主線程的 print(myList) 先于子進程的 print(list) 執(zhí)行。

在主進程里,只需要加一句代碼:

            
p1.join() # 等待子進程執(zhí)行完畢
print(myList)


          

['a', 'b', 'c']
['a', 'b']

執(zhí)行的順序就不一樣了。

分布式進程數(shù)據(jù)共享

通過 Manager 實現(xiàn)數(shù)據(jù)共享。

Manager會創(chuàng)建一個服務(wù)進程,其他的進程都統(tǒng)一來訪問這個server進程,從而達到多進程之間的數(shù)據(jù)通信。

一旦主進程結(jié)束,則server進程也講結(jié)束

1、不多說,直接上代碼

            
# coding: utf-8
from multiprocessing import Process, Manager
# 定義函數(shù)
def addUser(list):
  list.append("c") # 給list添加了一個元素
  print(list)
if __name__ == "__main__":
  mgr = Manager()
  my_list = mgr.list(["a","b"]) # 通過Manager對象創(chuàng)建list
  p1 = Process(target=addUser,args=(my_list,))
  p1.start()
  p1.join()
  print(my_list)


          

注意2次打印list,在子進程(addUser())里還改變了list數(shù)據(jù)。我們看看2次打印結(jié)果:

['a', 'b', 'c']
['a', 'b', 'c']

說明通過Manager對象創(chuàng)建的list數(shù)據(jù)能夠在進程之間通信了。

2、分布式的數(shù)據(jù)共享
https://docs.python.org/3/library/multiprocessing.html

2.1、創(chuàng)建一個server

datamgr.py內(nèi)容如下:

            
# coding: utf-8
from multiprocessing.managers import BaseManager
if __name__ == "__main__":
   mgr = BaseManager(address=('127.0.0.1', 50000), authkey=b'password')
   mgr.register("getUser", callable=lambda :["a","b"])
   # server永不關(guān)閉
   server = mgr.get_server()
   server.serve_forever()


          

作為數(shù)據(jù)提供者。

2.2、在test.py里(可能是另外一臺服務(wù)器里) 連接這個server

            
# coding: utf-8
from multiprocessing import Process, Manager
from multiprocessing.managers import BaseManager
if __name__ == "__main__":
  mgr = BaseManager(address=('127.0.0.1', 50000), authkey=b'password')
  mgr.register("getUser")
  mgr.connect() # 連接遠程的server
  my_list = mgr.getUser() # 從server獲取數(shù)據(jù)
  print(my_list) # ['a', 'b']


          

連上了,并獲取到了數(shù)據(jù)。

3、創(chuàng)建2個子進程,修改list數(shù)據(jù),看看是不是能夠共享?

            
# 定義函數(shù)
def addUser(list):
  list.append("c")
def addUser2(list):
  list.append("d")
if __name__ == "__main__":
  mgr = BaseManager(address=('127.0.0.1', 50000), authkey=b'password')
  mgr.register("getUser")
  mgr.connect() # 連接遠程的server
  my_list = mgr.getUser() # 從server獲取數(shù)據(jù)
  # 創(chuàng)建2個子進程
  p1 = Process(target=addUser,args=(my_list,))
  p1.start()
  p2 = Process(target=addUser2, args=(my_list,))
  p2.start()
  # 等待2個子進程執(zhí)行完畢
  p1.join()
  p2.join()
  # 在主進程打印最終的list
  print(my_list) # ['a', 'b', 'c', 'd']


          

顯然,在子進程里往list添加數(shù)據(jù)有效。

更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《Python進程與線程操作技巧總結(jié)》、《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》、《Python入門與進階經(jīng)典教程》、《Python+MySQL數(shù)據(jù)庫程序設(shè)計入門教程》及《Python常見數(shù)據(jù)庫操作技巧匯總》

希望本文所述對大家Python程序設(shè)計有所幫助。


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 久久国产精品高清一区二区三区 | 欧美一级影院 | 国产精品午夜激爽毛片 | 久草在线观看免费 | 欧美性视频一区二区三区 | 国产主播福利在线 | 色图综合网 | 人妖粗暴刺激videos | α片毛片 | 天天操人人射 | a久久| 久久婷婷五月综合色丁香 | 大片在线播放日本一级毛片 | 国产成人aa视频在线观看 | 中文字幕精品视频 | 全午夜免费一级毛片 | 狠狠综合欧美综合欧美色 | 日韩精品久久不卡中文字幕 | 在线看片不卡 | 久精品在线观看 | 久久成人国产精品 | 欧美亚洲精品小说一区二三区 | 欧美亚洲一区二区三区在线 | 综合另类小说色区色噜噜 | 久久免视频| 午夜免费体验区 | 免费的性生活视频 | 亚洲综合色就色手机在线观看 | 福利视频专区 | 大美女久久久久久j久久 | 欧美精欧美乱码一二三四区 | 日本xoxo| 伊人久久大香线蕉综合bd高清 | 日本不卡高清免费v | 肉漫天堂 | 99久久99热久久精品免 | 成 人 黄 色 视频 免费观看 | 国产综合社区 | 神马影院我不卡手机版 | 美女个护士一级毛片亚洲 | 爱视频福利网 |