pythonapply_async函数_Pythonapply_async不执行函数

嗨&＃xff0c;我想用多处理来加速我的代码。但是&＃xff0c;apply_async对我不起作用。我试着做一个简单的例子&＃xff0c;比如&＃xff1a;from multiprocessing.pool import Pool

t &＃61; [0, 1, 2, 3, 4, 5]

def cube(x):

t[x] &＃61; x**3

pool &＃61; Pool(processes&＃61;4)

for i in range(6):

pool.apply_async(cube, args&＃61;(i, ))

for x in t:

print(x)

它并没有像我所期望的那样真正改变t。

我真正的密码是&＃xff1a;from multiprocessing.pool import Pool

def func(a, b, c, d):

#some calculations

#save result to files

#no return value

lt &＃61; #list of possible value of a

#set values to b, c, d

p &＃61; Pool()

for i in lt:

p.apply_async(func, args&＃61;(i, b, c, d, ))

这里的问题在哪里&＃xff1f;

谢谢你&＃xff01;

更新&＃xff1a;感谢您的评论和回答&＃xff0c;现在我明白了为什么我的简单示例行不通。然而&＃xff0c;我的真实代码仍然有问题。我已经检查过我的func不依赖于任何全局变量&＃xff0c;因此它似乎与我的示例代码不是同一个问题。

如前所述&＃xff0c;我向我的func添加了一个返回值&＃xff0c;现在我的代码是&＃xff1a;f &＃61; Flux("reactor")

d &＃61; Detector("Ge")

mv &＃61; arange(-6, 1.5, 0.5)

p &＃61; Pool()

lt &＃61; ["uee", "dee"]

for i in lt:

re &＃61; p.apply_async(res, args&＃61;(i, d, f, mv, ))

print(re.get())

p.close()

p.join()

现在我得到以下错误&＃xff1a;Traceback (most recent call last):

File "/Users/Shu/Documents/Programming/Python/Research/debug.py", line 35, in

print(re.get())

File "/usr/local/Cellar/python3/3.6.0/Frameworks/Python.framework/Versions/3.6/lib/python3.6/multiprocessing/pool.py", line 608, in get

raise self._value

File "/usr/local/Cellar/python3/3.6.0/Frameworks/Python.framework/Versions/3.6/lib/python3.6/multiprocessing/pool.py", line 385, in _handle_tasks

put(task)

File "/usr/local/Cellar/python3/3.6.0/Frameworks/Python.framework/Versions/3.6/lib/python3.6/multiprocessing/connection.py", line 206, in send

self._send_bytes(_ForkingPickler.dumps(obj))

File "/usr/local/Cellar/python3/3.6.0/Frameworks/Python.framework/Versions/3.6/lib/python3.6/multiprocessing/reduction.py", line 51, in dumps

cls(buf, protocol).dump(obj)

AttributeError: Can&＃39;t pickle local object &＃39;Flux.__init__..&＃39;