快捷導(dǎo)航

python多進程操作實例

更新時間：2014年11月21日 10:16:06 投稿：junjie

這篇文章主要介紹了python多進程操作實例,本文講解了multiprocessing類的相關(guān)方法,然后給出了一個綜合實例和運行效果,需要的朋友可以參考下

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

一、多進程

process的成員變量和方法：

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

>>name, pid

分別表示進程的名字，進程id。

>> daemon成員

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

注意：

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

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

>> exitcode

如果進程還沒有退出，則為None，如果正確的退出則為0，如果有錯誤則為>0的錯誤代碼，如果進程為終止則為-1*singal。

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

start()用來啟動進程，is_live()用來查看進程的狀態(tài)，terminate()用來終止進程。

>> run()

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

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

>> multiprocessing.cpu_count()

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

>> multiprocessing.active_children()

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

實例：

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