def get_version_list(env):
list = []
#do some intensive work
return list
if __name__ == '__main__':
from multiprocessing import Pool
pool = Pool()
result1 = pool.apply_async(get_version_list, ['prod'])
result2 = pool.apply_async(get_version_list, ['uat'])
#etc, I have six environment to check.
alist = result1.get()
blist = result2.get()
理想情况下,我希望有一个包含我的六个环境的列表,并在该列表上循环为每个环境调用我的函数(并行),然后合并所有返回的列表。联合列表不应多次包含一个值。在
类似这样的东西(我知道代码不起作用,但它给出了一个想要做什么的想法)
^{pr2}$有简单的方法吗?在
使用
map_async
代替apply_async
。在现在
x
将是结果列表。在相关问题 更多 >
编程相关推荐