python模拟事件触发机制详解-创新互联
本文实例为大家分享了python模拟事件触发机制的具体代码,供大家参考,具体内容如下
创新互联公司专注于云梦企业网站建设,响应式网站开发,商城网站定制开发。云梦网站建设公司,为云梦等地区提供建站服务。全流程按需策划,专业设计,全程项目跟踪,创新互联公司专业和态度为您提供的服务EventManager.py
# -*- encoding: UTF-8 -*- # 系统模块 from queue import Queue, Empty from threading import * class EventManager: def __init__(self): """初始化事件管理器""" # 事件对象列表 self.__eventQueue = Queue() # 事件管理器开关 self.__active = False # 事件处理线程 self.__thread = Thread(target = self.__Run) # 这里的__handlers是一个字典,用来保存对应的事件的响应函数 # 其中每个键对应的值是一个列表,列表中保存了对该事件监听的响应函数,一对多 self.__handlers = {} # {事件类型:[处理事件的方法]} def __Run(self): """引擎运行""" while self.__active == True: try: # 获取事件的阻塞时间设为1秒 event = self.__eventQueue.get(block = True, timeout = 1) self.__EventProcess(event) except Empty: pass def __EventProcess(self, event): """处理事件""" # 检查是否存在对该事件进行监听的处理函数 if event.type_ in self.__handlers: # 若存在,则按顺序将事件传递给处理函数执行 for handler in self.__handlers[event.type_]: handler(event) def Start(self): """启动""" # 将事件管理器设为启动 self.__active = True # 启动事件处理线程 self.__thread.start() def Stop(self): """停止""" # 将事件管理器设为停止 self.__active = False # 等待事件处理线程退出 self.__thread.join() def AddEventListener(self, type_, handler): """绑定事件和监听器处理函数""" # 尝试获取该事件类型对应的处理函数列表,若无则创建 try: handlerList = self.__handlers[type_] except KeyError: handlerList = [] self.__handlers[type_] = handlerList # 若要注册的处理器不在该事件的处理器列表中,则注册该事件 if handler not in handlerList: handlerList.append(handler) def RemoveEventListener(self, type_, handler): """移除监听器的处理函数""" #读者自己试着实现 def SendEvent(self, event): """发送事件,向事件队列中存入事件""" self.__eventQueue.put(event) """事件对象""" class Event: def __init__(self, type_=None): self.type_ = type_ # 事件类型 self.dict = {} # 字典用于保存具体的事件数据
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
文章名称:python模拟事件触发机制详解-创新互联
网站URL:http://scyanting.com/article/jeoej.html