大家好，最近在完善手头上一个基于事件系统的 GUI 。

现在遇到一个问题，就是当我在执行一个按钮点击事件的时候，实际会开一个子线程进行业务逻辑的处理，这个处理过程可能会比较长，并且中间可能会出现一些不符合预期的情况发生，当发生这种情况时，我希望会借由发送一个错误的事件通知 EventManager，然后调用 listener 的方法来立刻终结这个对应的错误线程（因为之前已经发生了错误了，后续逻辑代码继续执行没有意义了）

代码如下，大佬们直接复制运行即可观察。如能解答，万分感谢！

from queue import Queue, Empty from threading import * from tkinter import * import time from tkinter import ttk  EVENT_TYPE_1 = "Count" EVENT_TYPE_2 = "Error" MAX_NUMBER = 10 CUR_NUMBER = 0   class event_manager:     def __init__(self):         self._eventQueue = Queue()         self._thread = Thread(target=self.Run, daemon=True)         self._handlers = {}         self._active = False      def Start(self):         self._active = True         self._thread.start()      def Run(self):         while self._active is True:             try:                 event = self._eventQueue.get(block=True, timeout=1)                 self.Process(event)             except Empty:                 pass      def Process(self, event):         if event.type in self._handlers:             for handler in self._handlers[event.type]:                 handler()         else:             pass      def Stop(self):         self._active = False         self._thread.join()      def addEventListenter(self, type_, handler):         try:             handlerList = self._handlers[type_]          except KeyError:             handlerList = []             self._handlers[type_] = handlerList          if handler not in handlerList:             handlerList.append(handler)      def removeEventListenter(self, type_, handler):         try:             handlerList = self._handlers[type_]             if handler in handlerList:                 handlerList.remove(handler)             if not handlerList:                 del self._handlers[type_]         except KeyError:             pass      def sendEvent(self, event):         self._eventQueue.put(event)   class Event:     def __init__(self, event_event_name, cur_done_task, type_=None):         self.type = type_         self._event_name = event_event_name         self._curDoneTask = cur_done_task   class EventSource:     def __init__(self, event_name, event_mgr, max_number, type):         self._event_name = event_name         self._event_manager = event_mgr         self._type = type         self._max_number = max_number      def count(self):         global CUR_NUMBER         for i in range(self._max_number):             CUR_NUMBER = i + 1              if CUR_NUMBER == 4:  # 在业务逻辑线程中增加检测环节，如果发生错误就会发送错误事件，希望可以立刻终结当前的线程，不执行后续的代码                 print("************ detect error occurred , this thread should be terminated immediately !")                 errorEvent = Event("error", CUR_NUMBER, type_=EVENT_TYPE_2)                 self._event_manager.sendEvent(errorEvent)              print(                 "************ main thread start：now start process {} - count : {}".format(self._event_name, CUR_NUMBER))             event = Event("test", CUR_NUMBER, type_=self._type)             self._event_manager.sendEvent(event)             time.sleep(1)   class GUIListener(Tk):     def __init__(self):         super(GUIListener, self).__init__()          self.title("Progress GUI")         self.geometry("1200x805+600+100")         self.config(bg="#535353")         self.resizable(True, True)         self.taskThread = None          self.progressBar = ttk.Progressbar(master=self, orient=HORIZONTAL, maximum=MAX_NUMBER, length=300)         self.progressBar.pack()         self.button = ttk.Button(self, text="Run", command=lambda: self.button_function(MAX_NUMBER))         self.button.pack()      def update_progress_value(self):         print("************Sub thread start: detect progress bar value is now...{}".format(self.progressBar['value']))         self.progressBar['value'] = CUR_NUMBER         self.progressBar.update_idletasks()         print("************Sub thread start: update progress bar value to...{}".format(CUR_NUMBER))      def button_function(self, max_number):         # 在正式开始执行逻辑子线程之前，确实可以提前做一些判断，来决定是否满足条件，开始接下来的逻辑子线程，但是这个不在本次讨论范围内         es = EventSource("eventSource", eventMgr, max_number, EVENT_TYPE_1)         self.taskThread = Thread(target=es.count, daemon=True).start()  # 这里开始执行实际的业务逻辑子线程      def terminate_error_thread(self):  # 这个方法在 GUIListener 接受到事件源发出的错误逻辑时被唤起，用来立刻终结正在执行事件源的线程，不做后续无用的代码逻辑处理         pass         # TODO: but how to implement this method ？   if __name__ == '__main__':     gui = GUIListener()      eventMgr = event_manager()     eventMgr.addEventListenter(EVENT_TYPE_1, gui.update_progress_value)     eventMgr.addEventListenter(EVENT_TYPE_2, gui.terminate_error_thread)      eventMgr.Start()      gui.mainloop()  

顺便一提，希望得到的结果是这样的

************ main thread start：now start process eventSource - count : 1 ************Sub thread start: detect progress bar value is now...0.0 ************Sub thread start: update progress bar value to...1 ************ main thread start：now start process eventSource - count : 2 ************Sub thread start: detect progress bar value is now...1 ************Sub thread start: update progress bar value to...2 ************ main thread start：now start process eventSource - count : 3 ************Sub thread start: detect progress bar value is now...2 ************Sub thread start: update progress bar value to...3 ************ detect error occurred , this thread should be terminated immediately ! 

到这里就应该自然停止。