启动引擎
(self)
| 29 | self.__handlers = defaultdict(list) |
| 30 | |
| 31 | def __run(self): |
| 32 | """启动引擎""" |
| 33 | while self.__active: |
| 34 | try: |
| 35 | event = self.__queue.get(block=True, timeout=1) |
| 36 | handle_thread = Thread(target=self.__process, name="EventEngine.__process", args=(event,)) |
| 37 | handle_thread.start() |
| 38 | except Empty: |
| 39 | pass |
| 40 | |
| 41 | def __process(self, event): |
| 42 | """事件处理""" |