本文實(shí)例講述了Python使用multiprocessing創(chuàng)建進(jìn)程的方法。分享給大家供大家參考。具體分析如下：
進(jìn)程可以通過調(diào)用multiprocessing的Process進(jìn)行創(chuàng)建，下面代碼創(chuàng)建兩個(gè)進(jìn)程。
[root@localhost ~]# cat twoproces.py #!/usr/bin/env pythonfrom multiprocessing import Processimport osdef output(): print "My pid is :%d/n" % os.getpid() print "My parent is:%d/n" % os.getppid()def main(): p=Process(target=output) p.start() print "I am parent %d/n" % os.getpid()if __name__=="__main__": main()
運(yùn)行結(jié)果如下：
[root@localhost ~]# ./twoproces.py I am parent 7656My pid is :7660My parent is:7656
以下程序結(jié)果的mypid值將在兩個(gè)進(jìn)程中固定不變.
[root@localhost ~]# cat badprocessID.py #!/usr/bin/env pythonfrom multiprocessing import Processimport osdef output(mypid): print "I am child %d ID :%d/n" % (os.getpid(),mypid)def main(): mypid=os.getpid() p=Process(target=output,args=(mypid,)) print "I am parent %d/n" % os.getpid() p.start()if __name__=="__main__": main()
有與子進(jìn)程并沒有重設(shè)mypid，所以運(yùn)行過程中mypid并沒有任何改變。
下面代碼將創(chuàng)建一個(gè)由子進(jìn)程創(chuàng)建子進(jìn)程的進(jìn)程鏈。
[root@localhost ~]# cat simplechina.py #!/usr/bin/env pythonimport osfrom multiprocessing import Processdef output(howmany,childpid): info = (howmany,os.getpid(),os.getppid(),childpid) print "i:%d process ID:%d parent ID%d child ID %d/n" % infodef chain(howmany): howmany = howmany-1 if howmany > 0: p = Process(target=chain,args=(howmany,)) p.start() output(howmany,p.pid)def main(): childpid = 0 howmany=6 p = Process(target=chain,args=(howmany,)) p.start()if __name__=="__main__": main()
有與主進(jìn)程利用Process創(chuàng)建子進(jìn)程，而子進(jìn)程又再創(chuàng)建子進(jìn)程（也就是A->B->C-D），如此類推，知道howmany小于0結(jié)束。運(yùn)行1結(jié)果如下：
[root@localhost ~]# ./simplechina.py i:5 process ID:13581 parent ID13580 child ID 13582i:4 process ID:13582 parent ID13581 child ID 13583i:3 process ID:13583 parent ID13582 child ID 13584i:2 process ID:13584 parent ID13583 child ID 13585i:1 process ID:13585 parent ID13584 child ID 13586
接下來如何創(chuàng)建一個(gè)進(jìn)程扇,也就是：
A
/ /
B C
建立simplefan.py文件，代碼如下：
[root@localhost ~]# cat simplefan.py #!/usr/bin/env pythonimport osfrom multiprocessing import Processdef output(howmany,childpid): info = (howmany,os.getpid(),os.getppid(),childpid) print "i:%d process ID:%d parent ID%d child ID %d/n" % infodef fan(i): output(i,os.getpid())def main(): pList=[] for i in range(6): p = Process(target=fan,args=(i,)) pList.append(p) for p in pList: p.start() for p in pList: p.join()if __name__=="__main__": main()
運(yùn)行結(jié)果如下：
[root@localhost ~]# ./simplefan.py i:0 process ID:13594 parent ID13593 child ID 13594i:2 process ID:13596 parent ID13593 child ID 13596i:3 process ID:13597 parent ID13593 child ID 13597i:1 process ID:13595 parent ID13593 child ID 13595i:4 process ID:13598 parent ID13593 child ID 13598i:5 process ID:13599 parent ID13593 child ID 13599
除了進(jìn)程ID為13593的進(jìn)程外，其它進(jìn)程的父進(jìn)程都是13593
父進(jìn)程利用join方法等等所有的子進(jìn)程結(jié)束。
希望本文所述對大家的Python程序設(shè)計(jì)有所幫助。
新聞熱點(diǎn)
疑難解答
圖片精選
