我有一个像下面这样的要求
from multiprocessing import Pool
import pandas as pd
import time
def test():
print("Parent")
def opt_by_region(a,b,c,d):
print("inside process")
time.sleep(1)
return b
def opt():
pool=Pool(processes=4)
df=pd.DataFrame([1,2])
res=[pool.apply_async(fun,args=(r,df,3,4))for r in range(5)]
pool.close()
pool.join()
这是我正在工作的代码的示例结构。在这里,我只需要为每个区域并行运行“opt_by_region”。但是区域和其他变量是从函数“opt”获取的(它不是并行运行的)所以我怎么能解决这个问题。我怎么能把等待“opt_by_region”用函数“opt”中的所有变量触发。有人可以吗提出想法,将不胜感激。
首先,尝试从 pool.apply_async 中删除该列表理解。您希望向 apply_async 提供参数列表,即使列表元素是容器或对象。
接下来,我认为你有一个错字,应该提供你想要迭代的函数(有趣 <-> opt_by_region)
args = [(r,df,3,4) for r in range(5)]
res = pool.apply_async(opt_by_region,args=args)
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句