>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條評論
主站蜘蛛池模板: 沧元图免费观看 | 哪个网站能看毛片 | 天堂精品视频 | 一区二区中文字幕亚洲精品 | 奇米在线影视 | 亚洲欧美一区二区三区四区 | 在线观看中文字幕第一页 | 国产精品亚洲精品一区二区三区 | 天天操操操操 | 欧美成人香蕉网在线观看 | 国产精品视频视频久久 | 88国产经典欧美一区二区三区 | 欧美性色福利视频在线观看 | 四虎影院新网址 | 美女视频黄是免费的 | 国产成人亚洲精品91专区高清 | 国产二区精品视频 | 亚洲综合一区二区三区四区 | 超级碰碰青草久热国产 | 牛牛影视在线观看片免费 | 99久热在线精品视频播 | 国产成人精品一区二区仙踪林 | 天天干夜干| 成人影视在线观看 | 九九热欧美 | 亚洲一区二区三区四区热压胶 | 91最新免费观看在线 | 热久久国产精品 | 天天成人 | 毛片免费看看 | 国产福利第一页 | 这里只有精品国产 | 一级特级欧美a毛片免费 | 久操视频在线观看免费 | 国产伦精品一区二区三区视频小说 | 日本在线观看www | 99热在线这里只有精品 | 欧美无吗 | 久久综合免费视频 | 久久久久久久久久综合情日本 | 久久精品伊人 |