Używanie Pythona multiprocessing.Process klasę

Question

Jest to kwestia początkujących:

Klasa jest obiektem, więc mogę utworzyć klasę o nazwie pippo() i wewnątrz tej funkcji i dodać parametr, ja nie rozumiem, jeśli funkcje wewnątrz pippo są wykonywane od góry do dołu, gdy przypisuję x=pippo() lub muszę je nazwać x.dosomething() poza pippo.

Praca z pakietem wieloprocesorowej Pythona, lepiej jest określić wielką funkcję i utworzyć obiekt za pomocą target argument w wywołaniu Process(), lub stworzyć własną klasę proces poprzez dziedziczenie z Process klasie?

Answer 1

Często zastanawiałem się, dlaczego strona dokumentu Pythona na multiprocessing pokazuje tylko "funkcjonalne" podejście (używając parametru target). Prawdopodobnie dlatego, że zwięzłe, zwięzłe fragmenty kodu są najlepsze do celów ilustracyjnych. Dla małych zadań, które mieszczą się w jednej funkcji, mogę zobaczyć, jak to jest preferowanym sposobem, ala:

from multiprocessing import Process 

def f(): 
    print('hello') 

p = Process(target=f) 
p.start() 
p.join() 

Ale kiedy trzeba większą organizację kodu (dla złożonych zadań), tworzyć własne klasy jest droga :

from multiprocessing import Process 

class P(Process): 
    def __init__(self): 
     super(P, self).__init__() 
    def run(self): 
     print('hello') 

p = P() 
p.start() 
p.join() 

Należy pamiętać, że każdy zainicjowany proces jest inicjowany za pomocą kopii śladu pamięci głównego procesu. I że kod konstruktora (tj. Materiał wewnątrz __init__()) jest wykonywany w procesie głównym - tylko kod wewnątrz run() jest wykonywany w oddzielnych procesach.

Dlatego jeśli proces (master lub spawned) zmienia jego zmienną składową, zmiana nie zostanie odzwierciedlona w innych procesach. Jest to oczywiście prawdziwe tylko w przypadku typów wejściowych, takich jak: bool, string, list itd. Można jednak importować "specjalne" struktury danych z modułu multiprocessing, które są następnie przezroczyście dzielone między procesami (patrz Sharing state between processes.) Lub może tworzyć własne kanały IPC (komunikacja między procesami), takie jak multiprocessing.Pipe i multiprocessing.Queue.