Python使用multiprocessing创建进程的方法

   本文实例讲述了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程序设计有所帮助。

时间: 2025-01-10 16:05:59

Python使用multiprocessing创建进程的方法的相关文章

python类:class创建、数据方法属性及访问控制详解_python

在Python中,可以通过class关键字定义自己的类,然后通过自定义的类对象类创建实例对象. python中创建类 创建一个Student的类,并且实现了这个类的初始化函数"__init__": class Student(object):     count = 0     books = []     def __init__(self, name):         self.name = name 接下来就通过上面的Student类来看看Python中类的相关内容. 类构造和

python 读写、创建 文件的方法(必看)_python

python中对文件.文件夹(文件操作函数)的操作需要涉及到os模块和shutil模块. 得到当前工作目录,即当前Python脚本工作的目录路径: os.getcwd() 返回指定目录下的所有文件和目录名:os.listdir() 函数用来删除一个文件:os.remove() 删除多个目录:os.removedirs(r"c:\python") 检验给出的路径是否是一个文件:os.path.isfile() 检验给出的路径是否是一个目录:os.path.isdir() 判断是否是绝对路

python基于multiprocessing的多进程创建方法

  本文实例讲述了python基于multiprocessing的多进程创建方法.分享给大家供大家参考.具体如下: ? 1 2 3 4 5 6 7 8 9 import multiprocessing import time def clock(interval): while True: print ("the time is %s"% time.time()) time.sleep(interval) if __name__=="__main__": p = m

python开启多个子进程并行运行的方法_python

本文实例讲述了python开启多个子进程并行运行的方法.分享给大家供大家参考.具体如下: 这个python代码创建了多个process子进程,创建完成后先start(),最后统一join,这样所有子进程会并行执行. from multiprocessing import Process import sys, os import time def timetask(times): time.sleep(times) print time.localtime() def works(func, a

python实现在windows服务中新建进程的方法

  本文实例讲述了python实现在windows服务中新建进程的方法.分享给大家供大家参考.具体实现方法如下: 需要安装的软件:python和pywin32,我这里装的分别是python-2.6.amd64.pywin32-217.win-amd64-py2.6 文件名:dma_ws.py ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 #!python

Python使用Supervisor来管理进程的方法

  本文实例讲述了Python使用Supervisor来管理进程的方法.分享给大家供大家参考.具体分析如下: Supervisor可以启动.停止.重启*nix系统中的程序.也可以重启崩溃的程序. supervisord的一个守护进程,用于将指定的进程当做子进程来运行. supervisorctl是一个客户端程序,可以查看日志并通过统一的会话来控制进程. 看例子: 我们写了一个py脚本,用于往log文件中记录一条当前的时间. ? 1 2 3 4 5 6 7 8 9 10 root@ubuntu:/

多进程-python在自定义的函数中不停创建进程

问题描述 python在自定义的函数中不停创建进程 windows下,用python写了一个多进程的代码,遇到问题 from multiprocessing import Processdef count(): num = 100000 while num>0: num -= 1 print ""done""def creat(): p = Process(target=count) p.start() p.join()if __name__ == '__ma

python创建进程fork用法

  本文实例讲述了python创建进程fork用法.分享给大家供大家参考.具体分析如下: ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 #!coding=utf-8 import os ,traceback import time ''' fork()系统调用是Unix下以自身进程创建子进程的系统调用, 一次调用,两次返回,如果返回是0, 则是子进程,如果返回值>0,则是父进程(返回

python定时检查某个进程是否已经关闭的方法

  本文实例讲述了python定时检查某个进程是否已经关闭的方法.分享给大家供大家参考.具体如下: ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 import threading import time import os import subprocess def get_process_count(imagename): p = os.popen('tasklist /FI "IMAGENAME eq %s"' % imagen