在Tkinter中使用async与threading时停止按钮报错问题求助

你的代码点击停止按钮报错，主要是因为跨线程状态同步不安全、协程退出逻辑不完善，以及主线程被阻塞导致的。以下是修复后的完整代码和关键修改说明：

import random
import threading
import tkinter as tk
import asyncio


class ControlWindow(tk.Frame):

    def __init__(self, window=None):
        super().__init__()
        self.window = window

        tk.Button(window, text="Stop", command=self.stop).pack()

        self.thread = None
        self.tasks = None
        # 用线程安全的Event替代普通bool变量，确保跨线程状态通知可靠
        self.stop_event = threading.Event()
        self.run()

    def schedule_check(self):
        self.window.after(100, self.check_thread_status)

    def check_thread_status(self):
        if self.thread.is_alive():
            self.schedule_check()
        else:
            # 异步线程完全结束后再关闭窗口，避免资源未释放
            self.window.quit()

    def run(self):
        self.thread = threading.Thread(target=self.start_async_loop)
        self.thread.start()
        self.schedule_check()

    def start_async_loop(self):
        # 手动创建并管理asyncio事件循环，适配多线程场景
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        try:
            loop.run_until_complete(self.main_runner())
        finally:
            loop.close()

    async def main_runner(self):
        queue = asyncio.Queue()
        self.tasks = [
            asyncio.create_task(self.producer(queue)),
            asyncio.create_task(self.consumer(queue))
        ]
        try:
            await asyncio.gather(*self.tasks)
        except asyncio.CancelledError:
            # 捕获协程取消异常，避免控制台报错
            pass

    async def producer(self, queue):
        while not self.stop_event.is_set():
            ran = random.randint(0, 5)
            queue.put_nowait(ran)
            await asyncio.sleep(1)
        # 生产者退出前向队列发送结束信号，通知消费者停止
        await queue.put(None)

    async def consumer(self, queue):
        while True:
            res = await queue.get()
            if res is None:
                # 收到结束信号，退出循环
                queue.task_done()
                break
            print(res)
            queue.task_done()

    def stop(self):
        # 设置停止信号，触发生产者退出
        self.stop_event.set()
        # 取消未完成的协程任务
        if self.tasks:
            for task in self.tasks:
                if not task.done():
                    task.cancel()
        # 不直接调用thread.join()，避免阻塞Tk主线程导致界面假死

if name == "main":
root = tk.Tk()
ControlWindow(root)
root.mainloop()

### 关键修改点：
1. **线程安全状态管理**：用`threading.Event`替代普通`flag`变量，解决多线程下状态更新可见性问题
2. **消费者退出逻辑**：生产者停止后向队列发送`None`作为结束信号，让消费者能正常退出循环，避免无限等待
3. **异常捕获**：在`main_runner`中捕获`CancelledError`，消除协程被取消时的报错信息
4. **避免主线程阻塞**：移除`thread.join()`，改用Tk的`after`循环异步检查线程状态，保证界面始终响应
5. **独立事件循环**：手动创建并关闭asyncio事件循环，比`asyncio.run`更适配多线程运行场景

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