【发布时间】:2015-05-20 03:04:04
【问题描述】:
我正在尝试使用多处理模块在 Python 2.7 中并行化一个函数。不幸的是,在我的池函数中,我在传递多个参数时似乎遇到了错误。我试图将它们打包为元组列表、类和列表列表,所有这些似乎都给了我以下错误:
File "plot_gfs.py", line 132, in plot_data
results = pool.map(plot_var,args)
File "/opt/Python2.7/lib/python2.7/multiprocessing/pool.py", line 251, in map
return self.map_async(func, iterable, chunksize).get()
File "/opt/Python2.7/lib/python2.7/multiprocessing/pool.py", line 558, in get
raise self._value
AttributeError: 'str' object has no attribute 'name'
这是我的并行函数代码:
def plot_data(lats, lons, bounds):
lons2, lats2 = np.meshgrid(lons, lats)
x, y = basem(lons2, lats2)
pool = mp.Pool(4)
args = [('prmslmsl', 0, 'jet', 950, 1050, i, x, y, bounds)
for i in range(80)]
results = pool.map(plot_var, args)
pool.close()
pool.join()
注意:plot_var 函数标签是:
def plot_var(var_in):
【问题讨论】:
标签: python python-2.7 python-multiprocessing