我正在尝试与以下代码并行运行一个函数:
with Pool(processes=2) as pool:
r1 = pool.apply_async(func1, (arg1, arg3))
r2 = pool.apply_async(func1, (arg2, arg3))
print(len(r1.get()))
print(len(r2.get()))
pool.close()
pool.join()
在上面报告的代码之后,我还有更多的代码行可以执行,但是显然它们只是被忽略而不执行。
我有兴趣对从r1和r2获得的结果进行计算。
谢谢!
您不应该使用with ... as ...
语句在Python中运行函数。相反,您应该定义另一个函数或单独运行它。还不清楚您要使用该代码实现什么。