欢迎来到山村网

Python使用multiprocessing创建进程的方法

2019-03-02 13:52:12浏览:630 来源:山村网   
核心摘要:  本文实例讲述了Python使用multiprocessing创建进程的方法。分享给大家供大家参考。具体分析如下:  进程可以通过调用multi

  本文实例讲述了Python使用multiprocessing创建进程的方法。分享给大家供大家参考。具体分析如下:

  进程可以通过调用multiprocessing的Process进行创建,下面代码创建两个进程。

  ?

1 2 3 4 5 6 7 8 9 10 11 12 13 [root@localhost ~]# cat twoproces.py #!/usr/bin/env python from multiprocessing import Process import os def output(): print "My pid is :%dn" % os.getpid() print "My parent is:%dn" % os.getppid() def main(): p=Process(target=output) p.start() print "I am parent %dn" % os.getpid() if __name__=="__main__": main()

  运行结果如下:

  ?

1 2 3 4 [root@localhost ~]# ./twoproces.py I am parent 7656 My pid is :7660 My parent is:7656

  以下程序结果的mypid值将在两个进程中固定不变.

  ?

1 2 3 4 5 6 7 8 9 10 11 12 13 [root@localhost ~]# cat badprocessID.py #!/usr/bin/env python from multiprocessing import Process import os def output(mypid): print "I am child %d ID :%dn" % (os.getpid(),mypid) def main(): mypid=os.getpid() p=Process(target=output,args=(mypid,)) print "I am parent %dn" % os.getpid() p.start() if __name__=="__main__": main()

  有与子进程并没有重设mypid,所以运行过程中mypid并没有任何改变。

  下面代码将创建一个由子进程创建子进程的进程链。

  ?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 [root@localhost ~]# cat simplechina.py #!/usr/bin/env python import os from multiprocessing import Process def output(howmany,childpid): info = (howmany,os.getpid(),os.getppid(),childpid) print "i:%d process ID:%d parent ID%d child ID %dn" % info def 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结果如下:

  ?

1 2 3 4 5 6 [root@localhost ~]# ./simplechina.py i:5 process ID:13581 parent ID13580 child ID 13582 i:4 process ID:13582 parent ID13581 child ID 13583 i:3 process ID:13583 parent ID13582 child ID 13584 i:2 process ID:13584 parent ID13583 child ID 13585 i:1 process ID:13585 parent ID13584 child ID 13586

  接下来如何创建一个进程扇,也就是:

  A

  /

  B C

  建立simplefan.py文件,代码如下:

  ?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 [root@localhost ~]# cat simplefan.py #!/usr/bin/env python import os from multiprocessing import Process def output(howmany,childpid): info = (howmany,os.getpid(),os.getppid(),childpid) print "i:%d process ID:%d parent ID%d child ID %dn" % info def 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()

  运行结果如下:

  ?

1 2 3 4 5 6 7 [root@localhost ~]# ./simplefan.py i:0 process ID:13594 parent ID13593 child ID 13594 i:2 process ID:13596 parent ID13593 child ID 13596 i:3 process ID:13597 parent ID13593 child ID 13597 i:1 process ID:13595 parent ID13593 child ID 13595 i:4 process ID:13598 parent ID13593 child ID 13598 i:5 process ID:13599 parent ID13593 child ID 13599

  除了进程ID为13593的进程外,其它进程的父进程都是13593

  父进程利用join方法等等所有的子进程结束。

  希望本文所述对大家的Python程序设计有所帮助。

(责任编辑:豆豆)
下一篇:

ruby实现github第三方认证

上一篇:

ruby实现修改ubuntu下的hosts

  • 信息二维码

    手机看新闻

  • 分享到
打赏
免责声明
• 
本文仅代表作者个人观点,本站未对其内容进行核实,请读者仅做参考,如若文中涉及有违公德、触犯法律的内容,一经发现,立即删除,作者需自行承担相应责任。涉及到版权或其他问题,请及时联系我们 xfptx@outlook.com