如何在Python类中用多进程实现共享变量，解决GUI交互卡顿？

核心问题说明 #

多进程中每个进程拥有独立内存空间，原代码直接访问实例变量self.spot、self.actions_done无法实现跨进程共享；且GUI操作必须在主线程执行，否则会导致界面卡顿。以下是重构后的实现方案：

关键修改点 #

• 使用multiprocessing.Manager创建进程安全的共享变量，实现spot和actions_done的跨进程同步
• 用multiprocessing.Event实现优雅的进程退出机制，避免强制终止
• 确保GUI交互函数getInputFromUser运行在主线程，子进程仅负责后台点击任务

重构后代码 #

import multiprocessing
from multiprocessing import Manager, Event

# 模拟外部函数，替换为你的实际信号检查逻辑
def check_signal():
    import random
    return random.choice([True, False])

# 模拟外部点击函数，替换为你的实际点击逻辑
def click(pos):
    print(f"执行点击：坐标{pos}")

class Program():
    def __init__(self):
        # 创建进程管理器，生成跨进程共享变量
        manager = Manager()
        self.shared_data = manager.dict({
            "spot": (0, 0),
            "actions_done": 0
        })
        # 退出事件：用于通知子进程停止循环
        self.stop_event = Event()

        # 启动子进程，传入共享数据和退出信号
        self.click_process = multiprocessing.Process(
            target=self.clickSpot,
            args=(self.shared_data, self.stop_event)
        )
        self.click_process.start()

        # 启动GUI交互逻辑（必须在主线程执行）
        self.getInputFromUser()

    def getInputFromUser(self):
        while not self.stop_event.is_set():
            # 替换为你的GUI输入/显示逻辑
            user_input = input("输入坐标(x,y)或输入q退出：")
            if user_input.lower() == 'q':
                self.exit()
                break
            
            try:
                x, y = map(int, user_input.split(','))
                # 更新共享变量中的点击位置
                self.shared_data["spot"] = (x, y)
            except ValueError:
                print("输入格式错误，请输入x,y格式")
            
            # 显示当前已完成的操作次数
            print(f"已完成操作：{self.shared_data['actions_done']}次")

    def clickSpot(self, shared_data, stop_event):
        while not stop_event.is_set():
            signal_found = check_signal()
            if signal_found:
                current_spot = shared_data["spot"]
                click(current_spot)
                # 原子更新操作计数（进程安全）
                shared_data["actions_done"] += 1
                # 可添加短暂延迟，避免循环占用过多资源
                # import time
                # time.sleep(0.1)

    def exit(self):
        # 触发退出信号，通知子进程停止
        self.stop_event.set()
        # 等待子进程安全结束
        self.click_process.join()
        print("程序已退出")

if __name__ == "__main__":
    Program()

代码解释 #

1. 共享变量管理：Manager.dict()创建的字典是进程安全的，所有进程对它的读写都会自动同步，解决了普通变量跨进程无法共享的问题。如果需要更细粒度控制，也可以用Value（存单个数值）或Array（存数组）。
2. 优雅退出：Event对象的set()方法会让子进程中的stop_event.is_set()返回True，子进程将终止循环并安全退出，避免强制杀死进程导致的资源泄漏。
3. GUI主线程：getInputFromUser在主线程运行，所有界面交互操作都遵循GUI框架的主线程要求，彻底解决原多线程方案中的界面卡顿问题。

内容的提问来源于stack exchange，提问作者E1Bos