Pygame改用multiprocessing替代threading后按R键无响应问题求助

问题根源 #

• spawn启动机制触发重复初始化：Windows平台下Python的multiprocessing默认使用spawn模式创建子进程，子进程会重新导入整个主模块执行。如果你的pygame初始化代码pygame.init()、窗口创建代码写在全局作用域，没有包裹在if __name__ == "__main__"块内，每个子进程启动时都会重新执行一遍pygame初始化逻辑，就会重复打印初始化提示。
• 实例方法无法序列化导致子进程未正常执行：多进程间传递的所有对象都需要支持pickle序列化，你直接将绑定了实例的方法graph.draw_sth作为子进程target，实例方法无法被正常序列化，子进程启动后根本不会执行对应的绘图逻辑。
• 主进程未读取队列更新：你主循环内一直渲染的是初始创建的旧Board对象，即使子进程修改了队列中的Board，主进程没有主动从队列中拉取更新后的对象，自然看不到任何效果。

修复方案 #

1. 把所有pygame初始化、窗口创建的逻辑全部移入main()函数内，或者包裹在if __name__ == "__main__"块中，避免子进程导入时重复执行。
2. 将子进程要执行的逻辑改为普通函数，不要直接传实例方法作为target，队列作为普通参数传递给子进程即可。
3. 在主循环中增加非阻塞读取队列的逻辑，拿到子进程返回的更新后的Board对象后，替换当前渲染用的board实例。
4. 注意避免队列堆积，每次启动新的子进程前可以先清空队列中未处理的旧数据。

修改后代码示例 #

import multiprocessing
import pygame
from pygame.locals import *
from queue import Empty

class Board:
    # 代表2D网格的类，确保所有属性可pickle序列化
    pass

# 把绘图逻辑抽为普通函数，不要绑定类实例
def heavy_draw_task(q):
    # 从队列拿board
    board = q.get()
    # 执行耗时的绘图计算逻辑，修改board
    # ... 你的耗时逻辑
    # 修改完成后放回队列
    q.put(board)

def draw_board(surface, board):
    # 你的渲染逻辑
    pass

def main():
    # 所有pygame初始化逻辑放在main内部
    pygame.init()
    surface = pygame.display.set_mode((800, 600))
    clock = pygame.time.Clock()

    board = Board()
    q = multiprocessing.Queue()
    # 初始只放一次，后续子进程会把修改后的放回
    q.put(board)

    running = True
    while running:
        # 非阻塞读取队列，拿更新后的board
        try:
            updated_board = q.get_nowait()
            board = updated_board
            # 处理完要把board再塞回队列，供下次子进程调用
            q.put(board)
        except Empty:
            pass

        draw_board(surface, board)

        for event in pygame.event.get():
            if event.type == QUIT:
                running = False
            elif event.type == KEYDOWN:
                if event.key == pygame.K_r:
                    # 启动子进程，传入队列作为参数
                    p = multiprocessing.Process(target=heavy_draw_task, args=(q,))
                    p.daemon = True # 主进程退出时自动杀死子进程
                    p.start()

        pygame.display.update()
        clock.tick(60)

if __name__ == "__main__":
    main()

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