AttributeError: obiekt '_MainProcess' nie ma atrybutu '_exiting'

Question

Mam

AttributeError: '_MainProcess' object has no attribute '_exiting' 

z aplikacji Pythona. Niestety ten kod musi uruchomić Python 2.5, a zatem moduł processing obecnie znany jako multiprocessing. To, co robiłem, polega na utworzeniu obiektu Process z elementem oraz w kolejce z procesu głównego. Patrząc na kod processing.queue, widzę, że wątek podajnika jest uruchamiany. Ten wątek podajnika sprawdzi następnie currentProcess()._exiting, ale currentProcess() oceni jako _MainProcess, który nie ma wspomnianego atrybutu, co można zobaczyć w module processing.process. Jak rozwiązać ten problem? Czy jest to błąd w processing? Jeśli tak, czy mogę po prostu go zaimportować za pomocą currentProcess()._exiting = False?

Minimal przykład:

#!/usr/bin/python 

import processing 
import processing.queue 

class Worker(processing.Process): 
    def __init__(self): 
     processing.Process.__init__(self) 
     self.queue = processing.queue.Queue() 

    def run(self): 
     element = self.queue.get() 
     print element 

if __name__ == '__main__': 
    w = Worker() 
    w.start() 
    # To trigger the problem, any non-pickleable object is to be passed here. 
    w.queue.put(lambda x: 1) 
    w.join() 

Answer 1

Nie jestem pewien, dlaczego chcesz marynowane funkcję w tym przypadku, jeśli naprawdę chcesz to zrobić przyjrzeć się tej odpowiedzi: Is there an easy way to pickle a python function (or otherwise serialize its code)?

inaczej działa to dla Pythona 2.6 (wiem, że szukasz 2.5, ale nie mam 2,5). Zastąpiłem twoją funkcję lambda zwykłą funkcją i przekażę ją konstruktorowi przetwarzania:

from multiprocessing import Process, Queue 

def simple(): 
    return 1 

class Worker(Process): 
    def __init__(self, args): 
     Process.__init__(self, args=args) 
     self.queue = Queue() 

    def run(self): 
     element = self.queue.get() 
     print element 

if __name__ == '__main__': 
    w = Worker(args=[simple]) 
    w.start() 
    w.join()