Python多处理库错误（AttributeError：__exit__）

Question

使用时出现此错误pool.map(funct, iterable)：

AttributeError: __exit__

没有说明，仅堆栈跟踪到模块内的pool.py文件。

使用这种方式：

with Pool(processes=2) as pool:
   pool.map(myFunction, mylist)
   pool.map(myfunction2, mylist2)

我怀疑可挑剔性可能存在问题（python需要pickle将列表数据转换为字节流，或者将列表数据转换为字节流），但是我不确定这是否正确或是否要调试。

编辑：产生此错误的代码的新格式：

def governingFunct(list):
    #some tasks
    def myFunction():
         # function contents
    with closing(Pool(processes=2)) as pool:
         pool.map(myFunction, sublist)
         pool.map(myFunction2, sublist2)

产生错误：

PicklingError: Can't pickle <type 'function'>: attribute lookup __builtin__.function failed

Answer 1

在Python 2.x和3.0、3.1和3.2中，multiprocessing.Pool()对象 不是上下文管理器
。您不能在with语句中使用它们。只有在Python 3.3及更高版本中，您才可以使用它们。从Python
3multiprocessing.Pool()文档中
：

版本3.3中的新增功能
：池对象现在支持上下文管理协议–请参阅上下文管理器类型。__enter__()返回池对象，并__exit__()调用Terminate（）。

对于早期的Python版本，您可以使用contextlib.closing()，但要考虑到此调用
pool.close() ，而不是pool.terminate()。在这种情况下，请手动终止：

from contextlib import closing

with closing(Pool(processes=2)) as pool:
    pool.map(myFunction, mylist)
    pool.map(myfunction2, mylist2)
    pool.terminate()

或创建自己的terminating()上下文管理器：

from contextlib import contextmanager

@contextmanager
def terminating(thing):
    try:
        yield thing
    finally:
        thing.terminate()

with terminating(Pool(processes=2)) as pool:
    pool.map(myFunction, mylist)
    pool.map(myfunction2, mylist2)