Wieloprocesorowe przetwarzanie w Pythonie kończy się elegancko Jak?

Question

import multiprocessing 
import time 

class testM(multiprocessing.Process): 

    def __init__(self): 
     multiprocessing.Process.__init__(self) 
     self.exit = False 

    def run(self): 
     while not self.exit: 
      pass 
     print "You exited!" 
     return 

    def shutdown(self): 
     self.exit = True 
     print "SHUTDOWN initiated" 

    def dostuff(self): 
     print "haha", self.exit 


a = testM() 
a.start() 
time.sleep(3) 
a.shutdown() 
time.sleep(3) 
print a.is_alive() 
a.dostuff() 
exit() 

Zastanawiam się, jak to możliwe, że powyższy kod naprawdę nie drukuje "wyszedłeś". Co ja robię źle? jeśli tak, to czy ktoś może wskazać mi właściwy sposób na wyjście z wdziękiem? (Nie mam na myśli procesu process.terminate ani kill)

Answer 1

Powodem, dla którego nie widzisz tego, jest to, że nie komunikujesz się z podprocesorem. Próbujesz użyć zmiennej lokalnej (lokalnej do procesu nadrzędnego), aby zasygnalizować dziecku, że powinna ona zostać zamknięta.

Proszę spojrzeć na informacje na temat synchonization primatives. Musisz ustawić jakiś sygnał, który można przywołać w obu procesach. Gdy już to zrobisz, powinieneś być w stanie przesunąć przełącznik w procesie nadrzędnym i poczekać, aż dziecko umrze.

Wypróbuj poniższy kod:

import multiprocessing 
import time 

class MyProcess(multiprocessing.Process): 

    def __init__(self,): 
     multiprocessing.Process.__init__(self) 
     self.exit = multiprocessing.Event() 

    def run(self): 
     while not self.exit.is_set(): 
      pass 
     print "You exited!" 

    def shutdown(self): 
     print "Shutdown initiated" 
     self.exit.set() 


if __name__ == "__main__": 
    process = MyProcess() 
    process.start() 
    print "Waiting for a while" 
    time.sleep(3) 
    process.shutdown() 
    time.sleep(3) 
    print "Child process state: %d" % process.is_alive()