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

欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

python多進(jìn)程操作實(shí)例

系統(tǒng) 1990 0

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

一、多進(jìn)程

process的成員變量和方法:

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

>>name, pid

分別表示進(jìn)程的名字,進(jìn)程id。

>> daemon成員

daemon標(biāo)志位bool變量,需要在start()調(diào)用前設(shè)置。daemon的初始值是從父進(jìn)程繼承而來。當(dāng)一個(gè)進(jìn)程結(jié)束的時(shí)候,它嘗試去結(jié)束它的所有的daemon子進(jìn)程。

注意:

daemon進(jìn)程不允許創(chuàng)建子進(jìn)程。否則當(dāng)daemon進(jìn)程結(jié)束的時(shí)候它的子進(jìn)程不能被結(jié)束。

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

>>? exitcode

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

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

start()用來啟動(dòng)進(jìn)程,is_live()用來查看進(jìn)程的狀態(tài),terminate()用來終止進(jìn)程。

>> run()

可以在process的子類中重載run()方法,從而設(shè)定進(jìn)程的任務(wù)。重載process是構(gòu)造新進(jìn)程的另一種方式,一定程度上上等價(jià)于process的target參數(shù)。

multiprcessing的靜態(tài)方法:

>>? multiprocessing.cpu_count()

用來獲得當(dāng)前的CPU的核數(shù),可以用來設(shè)置接下來子進(jìn)程的個(gè)數(shù)。

>>? multiprocessing.active_children()

用來獲得當(dāng)前所有的子進(jìn)程,包括daemon和非daemon子進(jìn)程。

實(shí)例:

復(fù)制代碼 代碼如下:

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()

運(yùn)行結(jié)果:

python多進(jìn)程操作實(shí)例_第1張圖片

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


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

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

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

【本文對您有幫助就好】

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

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 欧美精品一区二区在线观看 | 欧美一级黄色片在线观看 | 亚洲iv一区二区三区 | 91视频区| 亚洲欧美一区二区三区情侣bbw | 亚洲一本 | 免费永久欧美性色xo影院 | 国产综合精品 | 国产农村妇女毛片精品久久麻豆 | 天天色图片 | 日韩欧美一区二区三区免费观看 | 久久婷五月综合 | 久草在线草a免费线看 | 猛h辣h高h文湿快穿np | 久久久久国产一区二区三区 | 国产精品国产三级国产播12软件 | 国产精品久久久久久久久免费 | 久久综合亚洲色综合 | 久草在 | 亚洲美女在线播放 | 热久久精品在线 | 亚洲国产婷婷香蕉久久久久久99 | aⅴ免费在线观看 | 日本三级一区二区三区 | 国产伦精品一区二区三区四区视频 | jzz 护士| 天天影视色香欲综合网老头 | 亚洲综合首页 | 中国一级大黄大黄大色毛片 | 中国xxnxx免费 | 亚洲视频不卡 | 新婚人妻不戴套国产精品 | 欧美精品在线免费观看 | 91成人免费电影 | 一级毛片 在线播放 | xifan在线a精品一区二区视频网站 | 亚洲欧洲精品成人久久奇米网 | 国产精品拍拍拍福利在线观看 | 色综合色综合 | 欧美xxxx狂喷水喷水 | 日日爽天天操 |