在类实例中复用multiprocessing.Pool结合tkinter定时执行的问题

算力阿峰

2026-7-4

问题根源

报错的核心原因是：当你用pool.map调用实例方法self.thread时，Python需要把这个方法序列化（pickle）后传递给子进程。而实例方法会绑定整个类实例，这就导致self.pool也被尝试序列化——但进程池对象本身不支持序列化，因此抛出NotImplementedError。

改写方案

方案1：将任务方法改为静态方法

把thread改为类的静态方法，这样它不会绑定实例，也就不会携带self.pool对象，从根源避免序列化问题：

import multiprocessing as mp
import tkinter as tk

class Test:
    def __init__(self):
        self.pool = mp.Pool()
        self.root = tk.Tk()
        # 先启动定时任务，再进入主循环
        self.exec()
        self.root.mainloop()

    def exec(self):
        # 调用静态方法，无需绑定实例
        result = self.pool.map(Test.thread, range(0, 4))
        for r in result:
            print(r)
        self.root.after(1000, self.exec)

    @staticmethod
    def thread(i):
        return i * 2

if __name__ == "__main__":
    Test()

方案2：使用独立函数作为任务

如果任务逻辑不需要和类绑定，直接写模块级的独立函数更简单：

import multiprocessing as mp
import tkinter as tk

# 独立任务函数，不依赖类实例
def thread(i):
    return i * 2

class Test:
    def __init__(self):
        self.pool = mp.Pool()
        self.root = tk.Tk()
        self.exec()
        self.root.mainloop()

    def exec(self):
        result = self.pool.map(thread, range(0, 4))
        for r in result:
            print(r)
        self.root.after(1000, self.exec)

if __name__ == "__main__":
    Test()