Python使用multiprocessing创建进程的方法
本文实例讲述了Python使用multiprocessing创建进程的方法。分享给大家供大家参考。具体分析如下：
进程可以通过调用multiprocessing的Process进行创建，下面代码创建两个进程。
[root@localhost~]#cattwoproces.py #!/usr/bin/envpython frommultiprocessingimportProcess importos defoutput(): print"Mypidis:%d\n"%os.getpid() print"Myparentis:%d\n"%os.getppid() defmain(): p=Process(target=output) p.start() print"Iamparent%d\n"%os.getpid() if__name__=="__main__": main()
运行结果如下：
[root@localhost~]#./twoproces.py Iamparent7656 Mypidis:7660 Myparentis:7656
以下程序结果的mypid值将在两个进程中固定不变.
[root@localhost~]#catbadprocessID.py #!/usr/bin/envpython frommultiprocessingimportProcess importos defoutput(mypid): print"Iamchild%dID:%d\n"%(os.getpid(),mypid) defmain(): mypid=os.getpid() p=Process(target=output,args=(mypid,)) print"Iamparent%d\n"%os.getpid() p.start() if__name__=="__main__": main()
有与子进程并没有重设mypid，所以运行过程中mypid并没有任何改变。
下面代码将创建一个由子进程创建子进程的进程链。
[root@localhost~]#catsimplechina.py #!/usr/bin/envpython importos frommultiprocessingimportProcess defoutput(howmany,childpid): info=(howmany,os.getpid(),os.getppid(),childpid) print"i:%dprocessID:%dparentID%dchildID%d\n"%info defchain(howmany): howmany=howmany-1 ifhowmany>0: p=Process(target=chain,args=(howmany,)) p.start() output(howmany,p.pid) defmain(): childpid=0 howmany=6 p=Process(target=chain,args=(howmany,)) p.start() if__name__=="__main__": main()
有与主进程利用Process创建子进程，而子进程又再创建子进程（也就是A->B->C-D），如此类推，知道howmany小于0结束。运行1结果如下：
[root@localhost~]#./simplechina.py i:5processID:13581parentID13580childID13582 i:4processID:13582parentID13581childID13583 i:3processID:13583parentID13582childID13584 i:2processID:13584parentID13583childID13585 i:1processID:13585parentID13584childID13586
接下来如何创建一个进程扇,也就是：
A
/ \
B C
建立simplefan.py文件，代码如下：
[root@localhost~]#catsimplefan.py #!/usr/bin/envpython importos frommultiprocessingimportProcess defoutput(howmany,childpid): info=(howmany,os.getpid(),os.getppid(),childpid) print"i:%dprocessID:%dparentID%dchildID%d\n"%info deffan(i): output(i,os.getpid()) defmain(): pList=[] foriinrange(6): p=Process(target=fan,args=(i,)) pList.append(p) forpinpList: p.start() forpinpList: p.join() if__name__=="__main__": main()
运行结果如下：
[root@localhost~]#./simplefan.py i:0processID:13594parentID13593childID13594 i:2processID:13596parentID13593childID13596 i:3processID:13597parentID13593childID13597 i:1processID:13595parentID13593childID13595 i:4processID:13598parentID13593childID13598 i:5processID:13599parentID13593childID13599
除了进程ID为13593的进程外，其它进程的父进程都是13593
父进程利用join方法等等所有的子进程结束。
希望本文所述对大家的Python程序设计有所帮助。