我需要一些帮助,我在 stackoverflow 和互联网上玩过多个选项。但我需要一些帮助,因为我很困惑。我在 Python 2.7 上。这是我的多处理经理。我只需要基于 n_iterations 迭代 function1 并收集每次迭代的结果。我已经导入了这两个库,from functools import partialimport multiprocessing功能1是;def function1(v1,v2,v3,v4,v5): calculate_function = v1+v2+v3+v4+v5 return calculate_function处理多处理的功能是,def multi_process(n_iterations,a1,a2,a3,a4,a5): sampling_process = partial(function1, v1=a1,v2=a2,v3=a3,v4=a4,v5=a5) pool = multiprocessing.Pool() results_set = pool.map(sampling_process, xrange(n_iterations)) pool.close() pool.join() return results_set但我不断收到一条错误消息, File "model_selection_pooling_ray.py", line 246, in multi_process results_set = pool.map(sampling_process, xrange(n_iterations)) File "/usr/lib/python2.7/multiprocessing/pool.py", line 251, in map return self.map_async(func, iterable, chunksize).get() File "/usr/lib/python2.7/multiprocessing/pool.py", line 567, in get raise self._valueNameError: global name 'valuofv1' is not defined(valueofv1 是 a1 的实际值)有人可以帮我弄清楚我做错了什么吗?谢谢你。
添加回答
举报
0/150
提交
取消