如何在另一个进程/线程中更改类对象的属性？

Question

例如，我有一个 Event 类，看起来像

class Event:
    def __init__(self):
        self.events = dict()

    def on(self, name, callback):
        self.events[name] = callback

    def emit(self, name):
        callback = self.events[name]
        if callable(callback):
            callback()

当我尝试在主线程中使用它时，它可以工作。

if __name__ == "__main__":
    event = Event()
    event.on("hello", lambda: print("hello world"))
    event.emit("hello")  # OUTPUT: hello world

但是当我尝试在另一个进程中注册我的事件时，它并没有改变，而是同一个进程。我已经定义了两个函数，其中一个设置新事件，另一个发出该事件。然后在不同的进程上运行这些函数。

def soldier(e):
    e.on("hello", lambda: print("hello world"))

def officer(e):
    e.emit("hello")

if __name__ == "__main__":
    event = Event()

    process1 = Process(target=officer, args=(event,))
    process2 = Process(target=soldier, args=(event,))

    process1.start()
    process2.start()

    process1.join()
    process2.join()

预期结果与上面没有进程的示例相同，但由于第一个进程仅在其内部更改 event.events 的值，并且更改的值在进程外部不可见，因此出现错误。

如何在进程外查看自定义类对象的变化值？

Answer 1

如果要使用Process，则需要使用管道、消息传递机制或某种方法在不同进程之间共享数据。每次启动一个进程（使用Process），数据都会被克隆，所以3个进程（主进程和创建的2个进程）中存在3个变量事件。

这里使用共享相同内存空间的轻进程线程更简单。在下面的示例中，变量事件是共享的。

import threading

class Event:
    def __init__(self):
        self.events = dict()

    def on(self, name, callback):
        self.events[name] = callback

    def emit(self, name):
        if name in self.events:
            callback = self.events[name]
            if callable(callback):
                callback()

def officer(e):
    e.on("hello", lambda: print("hello world"))

def soldier(e):
    e.emit("hello")

if __name__ == "__main__":
    event = Event()

    thread1 = threading.Thread(target=officer, args=(event,))
    thread2 = threading.Thread(target=soldier, args=(event,))

    thread1.start()
    thread2.start()

    thread1.join()
    thread2.join()
    

此外，您还必须添加一个安全机制，以确保该条目在使用之前已被注册。线程（或进程）的创建顺序并不能保证代码的执行顺序相同。