最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

 更新時(shí)間:2014年11月21日 10:16:06   投稿:junjie  
這篇文章主要介紹了python多進(jìn)程操作實(shí)例,本文講解了multiprocessing類的相關(guān)方法,然后給出了一個(gè)綜合實(shí)例和運(yùn)行效果,需要的朋友可以參考下

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

一、多進(jìn)程

process的成員變量和方法:

>>class multiprocessing.Process([group[, target[, name[, args[, kwargs]]]]]) 來(lái)的定義類似于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)程繼承而來(lái)。當(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)程也將被終止(對(duì)于非daemon進(jìn)程,父進(jìn)程不等待非daemon的紫子進(jìn)程,除非顯示地對(duì)非daemon子進(jìn)程使用join()方法)。

>>  exitcode

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

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

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

>> run()

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

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

>>  multiprocessing.cpu_count()

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

>>  multiprocessing.active_children()

用來(lái)獲得當(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é)果:

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

相關(guān)文章

最新評(píng)論

秀山| 加查县| 武穴市| 万盛区| 达孜县| 宝兴县| 临沭县| 阜新市| 门源| 全椒县| 铜山县| 搜索| 井陉县| 南郑县| 嘉善县| 唐海县| 天峨县| 闽清县| 台南县| 中阳县| 来凤县| 剑河县| 疏勒县| 门头沟区| 蓝田县| 和顺县| 彰化县| 晋城| 浑源县| 临漳县| 汉沽区| 涞水县| 加查县| 历史| 若羌县| 巴楚县| 普兰店市| 呼伦贝尔市| 长宁区| 昌黎县| 盈江县|