首页 > 系统服务 > 详细

进程池(Pool)

时间:2018-06-10 21:52:56      阅读:174      评论:0      收藏:0      [点我收藏+]

进程池用于进程维护, 当使用时,将会去进程池取数据   

 

from multiprocessing import Pool, Process
import os, time

def f(i):
time.sleep(2)
print(‘in process‘, os.getpid()) #os.getpid()获得进程序列号
return i+100

def Bar(arg):
print(‘exec done--‘, arg, os.getpid())


if __name__ == ‘__main__‘:
pool = Pool(5) #最多放入5个进程

for i in range(10):
pool.apply_async(func=f, args=(i,), callback=Bar) # callback回调函数, 子进程结束时,是否还做其他的事, apply_async是并行 和 apply是串行


print(‘end‘)
pool.close()
pool.join() #进程池中程序结束时,关闭进程池,忽略程序直接结束, 不能与join()变换位置

 

进程池(Pool)

原文:https://www.cnblogs.com/my-love-is-python/p/9164558.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!