多线程/多进程下向Tkinter ScrolledText插入文本的报错问题

我正在用Tkinter开发GUI自动化工具，核心流程：

• 点击按钮从主批处理文件生成大量子批处理文件
• 生成完成后向ScrolledText组件插入确认信息
• 根据CPU核心数并行执行所有批处理文件
• 将每个批处理的开始/结束时间插入ScrolledText组件

目前步骤1-3都能正常运行，控制台也能打印步骤4的时间信息，但尝试直接在子进程中调用run_text.insert()时触发错误：
NameError: name 'run_text' is not defined

尝试过重定向标准输出到ScrolledText但没成功，且认为这不是最优方案。以下是简化的模拟代码：

import tkinter as tk
from tkinter import *
import tkinter.scrolledtext as tkscrolled
import multiprocessing
from multiprocessing.pool import Pool
import datetime
import time
import threading
import random

robo_batch = []


def create_batch():
    for i in range(100):
        if run_text.compare("end-1c", "==", "1.0"):
            run_text.insert(END, f'File number {i} copied to location')
        else:
            run_text.insert(END, f'\nFile number {i} copied to location')

        robo_batch.append(f'{i}.bat')
    threading.Thread(target=execute_batch).start()


def execute_batch():
    if multiprocessing.cpu_count() >= 60:
        max_logical_processors = 60
    else:
        max_logical_processors = multiprocessing.cpu_count()

    with Pool(max_logical_processors) as pool:
        pool.map(task, robo_batch)


def task(identifier):
    print(f'{identifier}.bat started - {datetime.datetime.now().strftime("%d-%m-%Y %H:%M:%S")}')
    
    # 以下代码触发错误
    # run_text.insert(END,f'\n{identifier}.bat started - {datetime.datetime.now().strftime("%d-%m-%Y %H:%M:%S")}')

    time.sleep(random.randint(0, 9))

    print(f'{identifier}.bat finished - {datetime.datetime.now().strftime("%d-%m-%Y %H:%M:%S")}')


if __name__ == "__main__":

    root = Tk()

    root.geometry('825x874')
    root.geometry('+%d+%d' % (500, 50))

    run_text = tkscrolled.ScrolledText(root, height=35, width=105, padx=10, pady=10, font='Arial 10')
    run_text.insert(1.0, "")
    run_text.tag_configure("left", justify="left")
    run_text.tag_add("left", 1.0, "end")
    run_text.place(x=14, y=50)

    run_bttn = tk.Button(root, text="Run batch", command=lambda: create_batch())

    run_bttn.place(x=650, y=9)

    root.update()

    root.mainloop()

解决方案 #

问题根源：多进程环境中，子进程无法直接访问主进程的Tkinter组件。每个子进程有独立的内存空间，run_text是主进程创建的GUI对象，子进程根本看不到这个变量，所以触发NameError。

正确的做法是使用**进程间通信（IPC）**传递日志信息，让主进程负责更新GUI。具体步骤：

1. 创建multiprocessing.Queue，用于子进程向主进程发送日志消息
2. 修改task函数，将原本要插入ScrolledText的内容放入队列
3. 在主线程中启动一个守护线程，监听队列，一旦有消息就更新ScrolledText

修改后的完整代码：

import tkinter as tk
from tkinter import *
import tkinter.scrolledtext as tkscrolled
import multiprocessing
from multiprocessing.pool import Pool, Manager
import datetime
import time
import threading
import random

robo_batch = []
log_queue = None  # 全局队列，用于进程间通信


def create_batch():
    for i in range(100):
        if run_text.compare("end-1c", "==", "1.0"):
            run_text.insert(END, f'File number {i} copied to location')
        else:
            run_text.insert(END, f'\nFile number {i} copied to location')

        robo_batch.append(f'{i}.bat')
    threading.Thread(target=execute_batch).start()


def execute_batch():
    global log_queue
    if multiprocessing.cpu_count() >= 60:
        max_logical_processors = 60
    else:
        max_logical_processors = multiprocessing.cpu_count()

    # 使用Manager创建跨进程的队列
    with Manager() as manager:
        log_queue = manager.Queue()
        # 启动日志监听线程
        threading.Thread(target=listen_log_queue, daemon=True).start()
        
        with Pool(max_logical_processors) as pool:
            # 把队列传递给task函数
            pool.map(task, [(item, log_queue) for item in robo_batch])


def task(args):
    identifier, queue = args
    start_msg = f'\n{identifier}.bat started - {datetime.datetime.now().strftime("%d-%m-%Y %H:%M:%S")}'
    print(start_msg.strip())
    queue.put(start_msg)

    time.sleep(random.randint(0, 9))

    end_msg = f'\n{identifier}.bat finished - {datetime.datetime.now().strftime("%d-%m-%Y %H:%M:%S")}'
    print(end_msg.strip())
    queue.put(end_msg)


def listen_log_queue():
    """监听日志队列，更新GUI"""
    while True:
        msg = log_queue.get()
        # 使用Tkinter的after方法确保在主线程更新GUI
        run_text.after(0, lambda m=msg: run_text.insert(END, m))
        # 自动滚动到底部
        run_text.after(0, lambda: run_text.see(END))


if __name__ == "__main__":

    root = Tk()

    root.geometry('825x874')
    root.geometry('+%d+%d' % (500, 50))

    run_text = tkscrolled.ScrolledText(root, height=35, width=105, padx=10, pady=10, font='Arial 10')
    run_text.insert(1.0, "")
    run_text.tag_configure("left", justify="left")
    run_text.tag_add("left", 1.0, "end")
    run_text.place(x=14, y=50)

    run_bttn = tk.Button(root, text="Run batch", command=lambda: create_batch())

    run_bttn.place(x=650, y=9)

    root.mainloop()

关键说明 #

• 使用multiprocessing.Manager().Queue()创建跨进程共享的队列，普通Queue无法在Pool中使用
• 启动守护线程listen_log_queue，持续从队列取消息，并用run_text.after()在主线程更新GUI（Tkinter要求所有GUI操作必须在主线程执行）
• 子进程只负责生成日志消息放入队列，不直接操作GUI，避免跨进程访问组件的问题

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