Python Đa Lib Lỗi (AttributeError: __exit__)

Question

Am nhận được lỗi này khi sử dụng pool.map(funct, iterable):

AttributeError: __exit__ 

Không Giải thích, chỉ ngăn xếp dấu vết đến tập tin pool.py trong mô-đun.

sử dụng theo cách này:

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

Tôi nghi ngờ có thể là một vấn đề với các picklability (nhu cầu python để pickle, hoặc chuyển đổi dữ liệu danh sách vào dòng byte) nhưng tôi không chắc chắn nếu điều này là đúng hoặc nếu đó là cách gỡ lỗi.

EDIT: Định dạng mới của mã sản xuất lỗi này:

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

LỖI SẢN XUẤT:

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

Answer 1

Trong Python 2.x và 3.0, 3.1 và 3.2, multiprocessing.Pool() đối tượng là cán bộ quản lý không bối cảnh. Bạn không thể sử dụng chúng trong câu lệnh with. Chỉ trong Python 3.3 trở lên bạn mới có thể sử dụng chúng như vậy. Từ Python 3 multiprocessing.Pool() documentation:

New in version 3.3: Pool objects now support the context management protocol – see Context Manager Types. __enter__() returns the pool object, and __exit__() calls terminate().

Đối với phiên bản Python trước đó, bạn có thể sử dụng contextlib.closing(), nhưng đưa vào tài khoản này sẽ gọi pool.close(), không pool.terminate(). Chấm dứt bằng tay trong trường hợp đó:

from contextlib import closing 

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

hoặc tạo của riêng quản lý terminating() ngữ cảnh của bạn:

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) 

Answer 2

with tuyên bố là dành cho đối tượng có __enter__ và __exit__ chức năng, tức là Context Manager Types
multiprocessing.Pool là không phải Loại Trình quản lý Ngữ cảnh. thử làm như sau:

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