详解Python实现多进程异步事件驱动引擎
时间:2019-03-31
本文章向大家介绍详解Python实现多进程异步事件驱动引擎,主要包括详解Python实现多进程异步事件驱动引擎使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本文介绍了详解Python实现多进程异步事件驱动引擎,分享给大家,具体如下:
多进程异步事件驱动逻辑
逻辑
code
# -*- coding: utf-8 -*- ''' author: Jimmy contact: 234390130@qq.com file: eventEngine.py time: 2017/8/25 上午10:06 description: 多进程异步事件驱动引擎 ''' __author__ = 'Jimmy' from multiprocessing import Process, Queue class EventEngine(object): # 初始化事件事件驱动引擎 def __init__(self): #保存事件列表 self.__eventQueue = Queue() #引擎开关 self.__active = False #事件处理字典{'event1': [handler1,handler2] , 'event2':[handler3, ...,handler4]} self.__handlers = {} #保存事件处理进程池 self.__processPool = [] #事件引擎主进程 self.__mainProcess = Process(target=self.__run) #执行事件循环 def __run(self): while self.__active: #事件队列非空 if not self.__eventQueue.empty(): #获取队列中的事件 超时1秒 event = self.__eventQueue.get(block=True ,timeout=1) #执行事件 self.__process(event) else: # print('无任何事件') pass #执行事件 def __process(self, event): if event.type in self.__handlers: for handler in self.__handlers[event.type]: #开一个进程去异步处理 p = Process(target=handler, args=(event, )) #保存到进程池 self.__processPool.append(p) p.start() #开启事件引擎 def start(self): self.__active = True self.__mainProcess.start() #暂停事件引擎 def stop(self): """停止""" # 将事件管理器设为停止 self.__active = False # 等待事件处理进程退出 for p in self.__processPool: p.join() self.__mainProcess.join() #终止事件引擎 def terminate(self): self.__active = False #终止所有事件处理进程 for p in self.__processPool: p.terminate() self.__mainProcess.join() #注册事件 def register(self, type, handler): """注册事件处理函数监听""" # 尝试获取该事件类型对应的处理函数列表,若无则创建 try: handlerList = self.__handlers[type] except KeyError: handlerList = [] self.__handlers[type] = handlerList # 若要注册的处理器不在该事件的处理器列表中,则注册该事件 if handler not in handlerList: handlerList.append(handler) def unregister(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(object): #事件对象 def __init__(self, type =None): self.type = type self.dict = {} #测试 if __name__ == '__main__': import time EVENT_ARTICAL = "Event_Artical" # 事件源 公众号 class PublicAccounts: def __init__(self, eventManager): self.__eventManager = eventManager def writeNewArtical(self): # 事件对象,写了新文章 event = Event(EVENT_ARTICAL) event.dict["artical"] = u'如何写出更优雅的代码\n' # 发送事件 self.__eventManager.sendEvent(event) print(u'公众号发送新文章\n') # 监听器 订阅者 class ListenerTypeOne: def __init__(self, username): self.__username = username # 监听器的处理函数 读文章 def ReadArtical(self, event): print(u'%s 收到新文章' % self.__username) print(u'%s 正在阅读新文章内容:%s' % (self.__username, event.dict["artical"])) class ListenerTypeTwo: def __init__(self, username): self.__username = username # 监听器的处理函数 读文章 def ReadArtical(self, event): print(u'%s 收到新文章 睡3秒再看' % self.__username) time.sleep(3) print(u'%s 正在阅读新文章内容:%s' % (self.__username, event.dict["artical"])) def test(): listner1 = ListenerTypeOne("thinkroom") # 订阅者1 listner2 = ListenerTypeTwo("steve") # 订阅者2 ee = EventEngine() # 绑定事件和监听器响应函数(新文章) ee.register(EVENT_ARTICAL, listner1.ReadArtical) ee.register(EVENT_ARTICAL, listner2.ReadArtical) for i in range(0, 20): listner3 = ListenerTypeOne("Jimmy") # 订阅者X ee.register(EVENT_ARTICAL, listner3.ReadArtical) ee.start() #发送事件 publicAcc = PublicAccounts(ee) publicAcc.writeNewArtical() test()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
- HDUOJ-----X问题
- POJ-----C Looooops
- POJ--Strange Way to Express Integers
- HDUOJ----More is better(并查集)
- HDUOJ 1099——Lottery
- HDUOJ-----取(m堆)石子游戏
- HDUOJ-----Be the Winner
- HDUOJ-------- Fibonacci again and again
- HDUOJ----Good Luck in CET-4 Everybody!
- 进制转换
- HDUOJ--畅通工程
- poj----Ubiquitous Religions
- POJ----The Suspects
- HDUOJ----剪花布条
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Flutter以两种方式实现App主题切换的代码
- PHP中非常有用却鲜有人知的函数集锦
- PHP针对redis常用操作实例详解
- thinkPHP5使用Rabc实现权限管理
- PHP实现cookie跨域session共享的方法分析
- VS Code开发React-Native及Flutter 开启无线局域网安卓真机调试问题
- Laravel5.4简单实现app接口Api Token认证方法
- PHP生成zip压缩包的常用方法示例
- Android Studio用genymotion运行后小图标无法显示问题
- PHP7数组的底层实现示例
- 浅析Flutter AbsorbPointer 与 IgnorePointer的区别
- php用wangeditor3实现图片上传功能
- Flutter集成到已有iOS工程的方法步骤
- php的命名空间与自动加载实现方法
- Android Studio实现简易计算器(表格布局TableLayout)