DDR爱好者之家 Design By 杰米
本文实例讲述了Python使用multiprocessing创建进程的方法。分享给大家供大家参考。具体分析如下:
进程可以通过调用multiprocessing的Process进行创建,下面代码创建两个进程。
[root@localhost ~]# cat twoproces.py #!/usr/bin/env python from multiprocessing import Process import os def 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 7656 My pid is :7660 My parent is:7656
以下程序结果的mypid值将在两个进程中固定不变.
[root@localhost ~]# cat badprocessID.py #!/usr/bin/env python from multiprocessing import Process import os def 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 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 %d\n" % 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结果如下:
[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文件,代码如下:
[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 %d\n" % 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()
运行结果如下:
[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程序设计有所帮助。
DDR爱好者之家 Design By 杰米
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
DDR爱好者之家 Design By 杰米
暂无评论...
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
2025年04月22日
2025年04月22日
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]