进程池
进程池:
进程池内部维护一个进程序列,当使用时,则去进程池中获取一个进程,如果进程池序列中没有可供使用的进程,那么程序就会等待,直到进程池中有可用进程为止。
进程池中有俩个方法:
- apply(同步 一般不用)
apply_async(异步)
进程池示例:
from multiprocessing import Process,Pool
import time,os
def foo(i):
time.sleep(1)
print(i)
return i+100
if __name__ == '__main__':
pool = Pool(5)#创建进程池对象
for i in range(10):
pool.apply_async(func=foo,args=(i,))
pool.close()
pool.join()#join和close的调用顺序是固定的
print('over.......')
运行结果是:
1
0
4
2
3
5
8
6
7
9
over…….
一秒出现5个数字
加上回调函数的进程池:
from multiprocessing import Process,Pool
import time,os
def foo(i):
time.sleep(1)
print(i)
return 'hello %s'%i
def Bar(arg):
print(os.getpid())
print(os.getppid())
print('logger:',arg)
if __name__ == '__main__':
pool = Pool(5)#创建进程池对象
Bar(1)
print('.........')
for i in range(10):
pool.apply_async(func=foo,args=(i,),callback=Bar)
pool.close()
pool.join()#join和close的调用顺序是固定的
print('over.......')
运行结果是:
25624
28709
logger: 1
………
3
0
1
2
4
25624
28709
logger: hello 3
25624
28709
logger: hello 1
25624
28709
logger: hello 0
25624
28709
logger: hello 2
25624
28709
logger: hello 4
5
6
8
7
25624
28709
logger: hello 5
25624
28709
logger: hello 6
9
25624
28709
logger: hello 8
25624
28709
logger: hello 7
25624
28709
logger: hello 9
over…….
加上回调函数,回调函数是在主进程里执行的,所以回调函数可以统一的执行操作,而不必在子进程里每次执行。