Python Tkinter调用Thread.join()致程序崩溃的问题解决求助

核心问题总结 #

1. 直接在Tk主线程调用self.t1.join()会阻塞UI事件循环，导致程序冻结
2. 线程控制逻辑存在顺序错误与线程安全隐患
3. 关闭Toplevel窗口时未正确协调线程退出与窗口销毁的顺序

修正后的完整代码 #

import tkinter as tk
from tkinter import INSERT
import threading

class App(tk.Tk):
    def __init__(self):
        super().__init__()
        # 用线程安全的Event替代布尔变量控制线程
        self.thread_running = threading.Event()
        self.t1 = None  # 初始化线程对象，避免未启动时调用join报错

    ####### 线程执行函数 ##################
    def Bit_track(self, gud):
        # 循环判断事件是否处于激活状态
        while self.thread_running.is_set():
            # *** 这里替换为你的业务代码 ***
            # 建议添加短暂休眠，降低CPU占用
            # time.sleep(0.1)
            pass

    ######## 启动线程 ##########
    def bit_thread(self, gud, con_win):
        # 避免重复启动线程
        if self.t1 is not None and self.t1.is_alive():
            con_win.insert(INSERT, "线程已在运行\n")
            return
        
        self.t1 = threading.Thread(target=self.Bit_track, args=(gud,))
        con_win.insert(INSERT, "Thread started\n")
        self.thread_running.set()  # 激活事件，允许线程循环执行
        self.t1.start()

    ######## 停止线程 ##########
    def Bit_track_stop(self, gud, con_win):
        if not self.thread_running.is_set():
            con_win.insert(INSERT, "线程未运行\n")
            return
        
        self.thread_running.clear()  # 关闭事件，让线程退出循环
        con_win.insert(INSERT, "Thread stopping...\n")
        # 用after异步检查线程状态，避免阻塞主线程
        self.check_thread_exit(gud, con_win)

    def check_thread_exit(self, gud, con_win):
        if self.t1 is not None and self.t1.is_alive():
            # 每隔100ms检查一次线程状态
            self.after(100, self.check_thread_exit, gud, con_win)
        else:
            # 线程已退出，执行后续清理操作
            for i in range(2):
                for j in range(31):
                    gud[i][j].set(0)
            con_win.insert(INSERT, "Thread stopped\n")
            print("hello")
            self.t1 = None  # 重置线程对象

    ### Toplevel窗口关闭处理 ###
    def onclosing(self, newWin):
        if self.t1 is not None and self.t1.is_alive():
            self.thread_running.clear()
            # 等待线程退出后再关闭窗口
            self.wait_for_thread_close(newWin)
        else:
            newWin.destroy()

    def wait_for_thread_close(self, newWin):
        if self.t1 is not None and self.t1.is_alive():
            self.after(100, self.wait_for_thread_close, newWin)
        else:
            newWin.destroy()
            self.t1 = None

    def gui2_create(self):
        newWin = tk.Toplevel(self)
        newWin.title("Thread Control")
        
        # 示例组件（根据实际需求调整）
        fr3 = tk.Frame(newWin)
        fr3.pack(padx=10, pady=10)
        
        con_win = tk.Text(fr3, height=10, width=30)
        con_win.pack(pady=5)
        
        # 示例数据（根据实际需求调整）
        gud = [[tk.IntVar() for _ in range(31)] for _ in range(2)]
        
        bt1 = tk.Button(fr3, text="Start", width=10)
        bt2 = tk.Button(fr3, text="Stop", width=10)
        
        # 用lambda绑定按钮命令参数，避免延迟绑定问题
        bt1.configure(command=lambda: self.bit_thread(gud, con_win))
        bt2.configure(command=lambda: self.Bit_track_stop(gud, con_win))
        
        bt1.pack(side=tk.LEFT, padx=5)
        bt2.pack(side=tk.LEFT, padx=5)
        
        # 将窗口对象传递给关闭回调，方便控制销毁
        newWin.protocol("WM_DELETE_WINDOW", lambda: self.onclosing(newWin))

if __name__ == "__main__":
    app = App()
    app.gui2_create()
    app.mainloop()

关键修正点说明 #

1. 线程安全控制：用threading.Event替代布尔变量self.th1，其set()/clear()/is_set()方法是线程安全的，避免多线程下的变量不一致问题。
2. 避免主线程阻塞：删除直接调用self.t1.join()的代码，改用after()方法异步检查线程状态，保证Tk的UI事件循环正常运行。
3. 窗口关闭逻辑优化：关闭Toplevel时先触发线程退出，等待线程完全结束后再销毁窗口，避免线程与UI资源冲突。
4. 线程状态校验：启动/停止线程前先检查线程是否存活，避免重复操作或空指针错误。
5. 参数绑定修正：用lambda表达式绑定按钮命令的参数，解决原代码中ptr函数可能带来的参数传递问题。

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