Python Multi Lib Error (Attribute: __exit__)

Question

Am diesen Fehler, wenn die pool.map(funct, iterable) mit:

AttributeError: __exit__ 

Nein Erklärung, Stapel einzige Spur auf die pool.py Datei innerhalb des Moduls.

auf diese Weise mit:

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

ich vermute, es ein Problem mit dem picklability (Python Bedürfnisse pickle oder Listendaten in Byte-Stream-Transformation) sein könnte, aber ich bin mir nicht sicher, ob dies wahr ist oder wenn es um das Debuggen geht.

EDIT: neues Format von Code, der diesen Fehler erzeugt:

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

Fehler erzeugt hat:

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

Answer 1

In Python 2.x und 3.0, 3.1 und 3.2, multiprocessing.Pool() Objekte sind nicht Kontext Manager. Sie können sie nicht in einer with Anweisung verwenden. Nur in Python 3.3 und höher können Sie sie als solche verwenden. Von der 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().

Für frühere Python-Versionen, könnten Sie contextlib.closing(), verwenden aber berücksichtigen diese pool.close() nennen wollen, nicht pool.terminate(). Terminate manuell in diesem Fall:

from contextlib import closing 

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

oder erstellen Sie Ihre eigenen terminating() Kontext-Manager:

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 Aussage ist für Objekt, das __enter__ und __exit__ Funktionen, dh Context Manager Types
multiprocessing.Pool ist nicht Kontext-Manager-Typ. versuchen Sie wie folgt vor:

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