当我使用以下代码时，池结果总是返回超时，我在做的事情在逻辑上是否不正确？
from multiprocessing import Pool, Process, cpu_count
def add(num):
return num+1
def add_wrap(num):
new_num = ppool.apply_async(add, [num])
print new_num.get(timeout=3)
ppool = Pool(processes=cpu_count() )
test = Process(target=add_wrap, args=(5,)).start()
我知道this bug http://bugs.python.org/issue5331，并且会认为它会在 python 2.6.4 中得到修复吗？
您不能在进程之间传递 Pool 对象。
如果您尝试此代码，Python 将引发异常：“NotImplementedError：池对象无法在进程之间传递或腌制”。
from multiprocessing import Queue, Pool
q = Queue()
ppool = Pool(processes=2)
q.put([ppool])
ppool = q.get()
因此，如果您希望代码正常工作，只需在 add_wrap 方法中创建 Pool 对象即可。
from multiprocessing import Pool, Process, cpu_count
def add(num):
return num+1
def add_wrap(num):
ppool = Pool(processes=cpu_count() )
new_num = ppool.apply_async(add, [num])
print new_num.get(timeout=3)
test = Process(target=add_wrap, args=(5,)).start()
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
