>classmultiprocessing.Process([group[,target[,name[,args[,kwargs]]]]])" />

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

python多進程操作實例

系統 1917 0

由于CPython實現中的GIL的限制,python中的多線程其實并不是真正的多線程,如果想要充分地使用多核CPU的資源,在python中大部分情況我們需要使用多進程。 這也許就是python中多進程類庫如此簡潔好用的原因所在。在python中可以向多線程一樣簡單地使用多進程。

一、多進程

process的成員變量和方法:

>>class multiprocessing.Process([group[, target[, name[, args[, kwargs]]]]]) 來的定義類似于threading.Thread。target表示此進程運行的函數,args和kwargs表示target的參數。

>>name, pid

分別表示進程的名字,進程id。

>> daemon成員

daemon標志位bool變量,需要在start()調用前設置。daemon的初始值是從父進程繼承而來。當一個進程結束的時候,它嘗試去結束它的所有的daemon子進程。

注意:

daemon進程不允許創建子進程。否則當daemon進程結束的時候它的子進程不能被結束。

這里的daemon不是Unix的daemon進程,當父進程結束的時候所有的daemon子進程也將被終止(對于非daemon進程,父進程不等待非daemon的紫子進程,除非顯示地對非daemon子進程使用join()方法)。

>>? exitcode

如果進程還沒有退出,則為None,如果正確的退出則為0,如果有錯誤則為>0的錯誤代碼,如果進程為終止則為-1*singal。?

>> start(), is_live(), terminate()

start()用來啟動進程,is_live()用來查看進程的狀態,terminate()用來終止進程。

>> run()

可以在process的子類中重載run()方法,從而設定進程的任務。重載process是構造新進程的另一種方式,一定程度上上等價于process的target參數。

multiprcessing的靜態方法:

>>? multiprocessing.cpu_count()

用來獲得當前的CPU的核數,可以用來設置接下來子進程的個數。

>>? multiprocessing.active_children()

用來獲得當前所有的子進程,包括daemon和非daemon子進程。

實例:

復制代碼 代碼如下:

import multiprocessing
import time
import sys

def worker(num):
??? p = multiprocessing.current_process()
??? print ('Starting:' + p.name + ":" + str(p.pid))
??? print(str(num))
??? sys.stdout.flush()
??? print ('Exiting :' + p.name + ":" + str(p.pid))
??? sys.stdout.flush()

def daemon():
??? p = multiprocessing.current_process()
??? print ('Starting:' + p.name + ":" + str(p.pid))
??? sys.stdout.flush()
??? time.sleep(10)
??? print ('Exiting :' + p.name + ":" + str(p.pid))
??? sys.stdout.flush()
???
def non_daemon():
??? p = multiprocessing.current_process()
??? print ('Starting:' + p.name + ":" + str(p.pid))
??? sys.stdout.flush()
??? time.sleep(20)
??? print ('Exiting :' + p.name + ":" + str(p.pid))
??? sys.stdout.flush()
???
if __name__ == '__main__':
??? w = multiprocessing.Process(name='worker', target=worker, args=(100,))
??? d = multiprocessing.Process(name='daemon', target=daemon)
??? d.daemon = True
??? nd = multiprocessing.Process(name='non-daemon', target=non_daemon)
??? w.start()
??? d.start()
??? nd.start()
???
??? print("the number of CPU is " + str(multiprocessing.cpu_count()))
??? print("All children processes:")
??? for p in multiprocessing.active_children():
??????? print("child:" + p.name + ":" + str(p.pid))
??? print()
???
??? w.join()
??? #d.join()

運行結果:

python多進程操作實例_第1張圖片

可以從上面的例子看到沒有多非daemon子進程使用join()方法,結果父進程沒有等待非daemon進程結束就退出了。


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

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

【本文對您有幫助就好】

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

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 国产一级高清 | 天天操天天干天天射 | 色婷婷综合在线 | 操综合| 久久婷婷是五月综合色狠狠 | 伊在人亚洲香蕉精品播放 | 日日干日日爽 | 中文字幕 亚洲一区 | 午夜影院一区二区 | 毛片大片免费看 | 夜夜操操 | 成人久久网站 | 久久成人精品视频 | 超高清欧美videos360 | 99re热在线视频 | 黑人特级粗α级毛片 | 成人在线一区二区三区 | 超清中文乱码字幕在线观看 | 看全大色黄大色黄大片一级爽 | 亚洲涩涩视频 | 色片在线观看 | 国语一级毛片 | 中文字幕一区二区三区四区 | 亚洲视频一区二区三区四区 | 亚洲欧美成人在线 | 理论片黄色 | 国产精品a人片在线观看 | 97影院秋霞国产精品 | 亚洲精品免费日日日夜夜夜夜 | 91精品国产视频 | 成人欧美精品大91在线 | 久久综合伊人 | 亚洲韩精品欧美一区二区三区 | 男人的天堂一区二区视频在线观看 | 国产毛片一区二区 | 欧美一级xxxxⅹ毛片 | 久久久中文字幕 | 青草国产 | 香蕉视频在线免费看 | 伊人色综| 狠狠狠色丁香婷婷综合久久88 |