python多进程中使用pool

我就是我 2022-07-13 15:16 327阅读 0赞

[Python][] 多进程中使用pool，pool中指定每次运行几个进程，当其中一个进程结束完毕后，会加入新的进程

**\[python\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#!/usr/bin/env python  
2.  \#coding: utf-8  
3.  **import** multiprocessing  
4.  **import** os,time,random  
5.    
6.  **def** Lee():  
7.      **print** "Run task Lee-%s" %(os.getpid()) \#os.getpid()获取当前的进程的ID  
8.      start=time.time()  
9.      time.sleep(random.random()\*10) \#random.random()随机生成0-1之间的小数  
10.     end=time.time()  
11.     **print** 'Task Lee, runs %0.2f seconds.' %(end - start)  
12.   
13. **def** Marlon():  
14.     **print** "Run task Marlon-%s" %(os.getpid())  
15.     start=time.time()  
16.     time.sleep(random.random()\*40)  
17.     end=time.time()  
18.     **print** 'Task Marlon runs %0.2f seconds.' %(end - start)  
19.   
20. **def** Allen():  
21.     **print** "Run task Allen-%s" %(os.getpid())  
22.     start=time.time()  
23.     time.sleep(random.random()\*30)  
24.     end=time.time()  
25.     **print** 'Task Allen runs %0.2f seconds.' %(end - start)  
26.   
27. **def** Frank():  
28.     **print** "Run task Frank-%s" %(os.getpid())  
29.     start=time.time()  
30.     time.sleep(random.random()\*20)  
31.     end=time.time()  
32.     **print** 'Task Frank runs %0.2f seconds.' %(end - start)  
33.           
34. **if** \_\_name\_\_=='\_\_main\_\_':  
35.     function\_list=  \[Lee,Marlon,Allen,Frank\]   
36.     **print** "parent process %s" %(os.getpid())  
37.     pool=multiprocessing.Pool(2)  
38.     **for** func **in** function\_list:  
39.         pool.apply\_async(func) \#Pool执行函数，apply执行函数,当有一个进程执行完毕后，会添加一个新的进程到pool中  
40.     **print** 'Waiting for all subprocesses done...'  
41.     pool.close()  
42.     pool.join() \#调用join之前，一定要先调用close() 函数，否则会出错, close()执行后不会有新的进程加入到pool,join函数等待素有子进程结束  
43.     **print** 'All subprocesses done.'  
44.

[Python]: http://lib.csdn.net/base/11
[view plain]: http://blog.csdn.net/kobeyan/article/details/43852733#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/605539
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/605539/fork