>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條評論
主站蜘蛛池模板: 日本一区二区三区中文字幕 | 日韩欧美亚洲一区精选 | 国产一久久香蕉国产线看观看 | 精品无人区乱码1区2区3区在线 | 久草视频大全 | 久艾草国产成人综合在线视频 | 福利一区视频 | 伊人中文字幕在线 | 亚洲视频www| 国产亚洲在线观看 | 播放一级片| 久久图片| 天天射天天干天天插 | 国产精品免费看 | 夭天干天天做天天免费看 | 亚洲七七久久综合桃花 | 国产精品成aⅴ人片在线观看 | 羞羞网站视频 | 狠狠色噜噜噜噜狠狠狠狠狠狠奇米 | 亚洲一区二区三区首页 | 人人97| 一级特黄特黄的大片免费 | 国产成人理在线观看视频 | 亚洲国产高清精品线久久 | ass最极品女人下部pic | 成人免费一区二区三区在线观看 | 亚洲一区不卡视频 | 亚洲香蕉在线观看 | 欧美区日韩区 | 日日干天天操 | 成人午夜 | 久久久日韩精品国产成人 | 岛国大片在线观看 | 高清国产精品入口麻豆 | 真实偷清晰对白在线视频 | 欧美伦乱 | 亚洲一级免费视频 | 欧美国产日韩一区二区三区 | 热99精品在线 | 日韩高清一区二区三区不卡 | 亚洲精品www久久久久久久软件 |