>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條評論
主站蜘蛛池模板: 欧美一级夜夜爽 视频 | 成人欧美视频在线看免费 | 国产一级视频在线观看 | 亚洲人成网i8禁止 | 久久精品爱国产免费久久 | 天天爱天天干天天 | 四房快播 | 一区二区伦理 | 亚洲精品国产乱码在线播 | 日本a视频在线 | 精品亚洲欧美中文字幕在线看 | 深夜影院深a久久 | 久久九九有精品国产23百花影院 | 日韩一级a毛片欧美一级 | 五月婷婷婷婷婷 | 韩日性视频 | 九九热这里只有精品6 | 天天看天天射 | 久久不卡一区 | 99久久爱re热6在播放 | 涩涩免费播放观看在线视频 | x8x8国产日韩欧美 | 亚洲人成绝费网站色ww | 99在线热视频只有精品免费 | 四虎影视在线影院4hutv | 米奇777第四久久久99 | 天天综合天天做天天综合 | 男人的天堂在线视频 | 在线综合+亚洲+欧美中文字幕 | 2022国产男人亚洲欧美天堂 | 天天插夜夜 | 国产福利在线小视频 | 四虎影院黄色 | 精品无人区乱码1区2区3区在线 | 亚洲欧美日韩第一页 | xxxx免费国产在线视频 | 亚洲精品www久久久久久 | 国产福利视频在线播放 | 成人一级视频 | 色综合网站国产麻豆 | 日日摸夜夜夜夜夜添 |