本文实例讲述了python使用multiprocessing创建进程的方法。分享给大家供大家参考。具体分析如下：
进程可以通过调用multiprocessing的process进行创建，下面代码创建两个进程。
[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()
运行结果如下：
[root@localhost ~]# ./twoproces.py i am parent 7656my pid is :7660my parent is:7656
以下程序结果的mypid值将在两个进程中固定不变.
[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()
有与子进程并没有重设mypid，所以运行过程中mypid并没有任何改变。
下面代码将创建一个由子进程创建子进程的进程链。
[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()
有与主进程利用process创建子进程，而子进程又再创建子进程（也就是a->b->c-d），如此类推，知道howmany小于0结束。运行1结果如下：
[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
接下来如何创建一个进程扇,也就是：
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()
运行结果如下：
[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
除了进程id为13593的进程外，其它进程的父进程都是13593
父进程利用join方法等等所有的子进程结束。
希望本文所述对大家的python程序设计有所帮助。