Python中Tkinter结合多进程多线程出现RuntimeError问题求助

问题背景 #

程序设计逻辑：

• 主进程控制Tkinter窗口，负责数据展示
• 一个子进程包含两个线程：一个线程采集数据并放入队列，另一个线程从队列取数据发送至互联网，发送完成后通知主进程更新窗口文本框

运行时触发错误：

RuntimeError:
An attempt has been made to start a new process before the current process has finished its bootstrapping phase.
This probably means that you are not using fork to start your child processes and you have forgotten to use the proper idiom in the main module:
if name == 'main':
freeze_support()

错误原因 #

1. 多进程启动的强制规范：不管是否使用Tkinter，在Windows（或采用spawn启动方式的系统）下，Python多进程要求主模块的可执行代码必须包裹在if __name__ == '__main__':块内。因为子进程会重新导入主模块，没有这个判断会导致代码重复执行进程启动逻辑，触发递归创建进程的错误。
2. 代码中的其他问题：
   • 变量名错误：cola.get()应为queue.get()
   • 跨进程操作GUI：子进程直接调用main_window.after()违反Tkinter规则——Tkinter不是进程安全的，不能在子进程中操作主进程的GUI组件，必须通过队列让主进程自行处理界面更新。

解决步骤 #

• 将Tk窗口初始化、队列创建、进程/线程启动、主循环等代码全部放入if __name__ == '__main__':块
• 修正变量名错误
• 新增主进程线程，专门监听数据更新队列，触发GUI刷新

修正后的代码 #

import multiprocessing as mp
import threading
import time
import tkinter as tk

def take_data(queue):
    while True:
        data = [1, 2, 3, 4, 5]
        queue.put(data)
        time.sleep(1)

def send_data_internet(data_queue, update_queue):
    while True:
        local_data = data_queue.get()
        print("Sending data to internet:", local_data)
        # 将更新数据发送到主进程的更新队列
        update_queue.put(local_data)

def refresh_label(data):
    label_data.config(text=str(data))

def listen_update_queue(update_queue):
    # 主进程线程，监听更新队列并触发GUI刷新
    while True:
        data = update_queue.get()
        main_window.after(0, refresh_label, data)

if __name__ == '__main__':
    # 初始化主进程Tk窗口
    main_window = tk.Tk()
    label_data = tk.Label(main_window, text="waiting data")
    label_data.pack()

    # 数据队列：子进程内部传递采集的数据
    data_queue = mp.Queue()
    # 更新队列：子进程通知主进程更新GUI
    update_queue = mp.Queue()

    # 启动子进程：负责数据采集和发送
    secundary_process = mp.Process(target=send_data_internet, args=(data_queue, update_queue))
    # 子进程内的采集线程
    thread_local_data = threading.Thread(target=take_data, args=(data_queue,))

    # 主进程的监听线程，处理GUI更新（设为守护线程随主窗口关闭而终止）
    update_thread = threading.Thread(target=listen_update_queue, args=(update_queue,), daemon=True)

    secundary_process.start()
    thread_local_data.start()
    update_thread.start()

    main_window.mainloop()

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