Jak mogę zaktualizować członków klasy w procesach? [duplikować]
Szukałem innych pytań, a to niezaakceptowane pytanie jest jedynym, które udało mi się znaleźć, które w jakiś sposób rozwiązuje ten problem i nie jest zbyt pomocne. Potrzebuję tego również do pracy z procesami, a nie wątkami.
Więc od podstaw napisałem przykładowy program, aby pokazać mój problem, powinieneś być w stanie go wkleić i będzie działać:
import multiprocessing
import time
class Apple:
def __init__(self, color):
self.color = color
def thinkAboutApple(apple):
while True:
print(apple.color)
time.sleep(2)
my_apple = Apple("red")
new_process = multiprocessing.Process(target=thinkAboutApple, args=(my_apple,))
new_process.start()
time.sleep(4)
print("new: brown")
my_apple.color = "brown"
#so that the program doesn't exit after time.sleep(4)
while True:
pass
# actual output | # wanted output
red | red
red | red
new: brown | new: brown
red | brown
red | brown
To mówi mi, że albo jabłko jest w dziwnym przypuszczeniu, że ma dwa kolory w tym samym czasie, LUB że jabłko nowego_procesu znajduje się w innej pozycji w pamięci RAM i jest oddzielone od jabłka w głównym procesie.
A więc pytanie brzmi: czy istnieje sposób, aby wskaźnik jabłka w procesie wskazywał to samo jabłko, czy też w pytoniczny sposób, aby wszystkie wystąpienia jabłka we wszystkich procesach były takie same? A jeśli mam to samo jabłko w wielu procesach i jeszcze więcej procesów bez jabłka, jak mogę upewnić się, że ich powierzchnia jest zawsze taka sama?
Odpowiedzi
Możesz wyprowadzić wyspecjalizowaną wersję Proxy
klasy używanej przez multiprocessing.BaseManager
(nieudokumentowaną), multiprocessing.managers.NamespaceProxy
która w przeciwieństwie do klasy bazowej, uwidacznia wszystkie jej metody i atrybuty. Jest to podobne do odpowiedzi @ shtse8 na powiązane pytanie o zduplikowane pytanie, ale zamieszczam je, aby wyjaśnić, jak to zrobić.
from multiprocessing import Process
from multiprocessing.managers import BaseManager, NamespaceProxy
import time
import types
class MyManager(BaseManager): pass # Avoid namespace pollution.
class Apple:
def __init__(self, color):
self.color = color
def Proxy(target):
""" Create a derived NamespaceProxy class for `target`. """
def __getattr__(self, key):
result = self._callmethod('__getattribute__', (key,))
if isinstance(result, types.MethodType):
def wrapper(*args, **kwargs):
self._callmethod(key, args)
return wrapper
return result
dic = {'types': types, '__getattr__': __getattr__}
proxy_name = target.__name__ + "Proxy"
ProxyType = type(proxy_name, (NamespaceProxy,), dic) # Create subclass.
ProxyType._exposed_ = tuple(dir(target))
return ProxyType
AppleProxy = Proxy(Apple)
def thinkAboutApple(apple):
while True:
print(f"apple.color: {apple.color}")
time.sleep(1)
if __name__ == '__main__':
MyManager.register('Apple', Apple, AppleProxy)
manager = MyManager()
manager.start()
my_apple = manager.Apple("red")
new_process = Process(target=thinkAboutApple, args=(my_apple,))
new_process.start()
time.sleep(2) # Allow other process to run a short while.
my_apple.color = "brown" # Change shared class instance.
time.sleep(2) # Allow other process to run at little while longer.
new_process.terminate()