电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Python Asyncio模塊實現的生產消費者模型的方法

瀏覽:110日期:2022-06-26 17:22:39

asyncio的關鍵字說明

event_loop事件循環:程序開啟一個無限循環,把一些函數注冊到事件循環上,當滿足事件發生的時候,調用相應的協程函數 coroutine協程:協程對象,指一個使用async關鍵字定義的函數,它的調用不會立即執行函數,而是會返回一個協程對象,協程對象需要注冊到事件循環,由事件循環調用。 task任務:一個協程對象就是一個原生可以掛起的函數,任務則是對協程進一步封裝,其中包含了任務的各種狀態 future:代表將來執行或沒有執行的任務結果。它和task上沒有本質上的區別 async/await關鍵字:async定義一個協程,await用于掛起阻塞的異步調用接口,在python3.4是使用asyncio.coroutine/yield from

在設計模式中,生產消費者模型占有非常重要的地位,這個模型在現實世界中也有很多有意思的對應場景,比如做包子的人和吃包子的人,當兩者速度不匹配時,就需要有一個模型來做匹配(偶合),實現做的包子都會依次消費掉。

import asyncioclass ConsumerProducerModel: def __init__(self, producer, consumer, queue=asyncio.Queue(), plate_size=6): # the plate holds 6pcs bread self.queue = queue self.producer = producer self.consumer = consumer self.plate_size = plate_size async def produce_bread(self): for i in range(self.plate_size): bread = f'bread {i}' await asyncio.sleep(0.5) # bread makes faster, 0.5s/pc await self.queue.put(bread) print(f’{self.producer} makes {bread}’) async def consume_bread(self): while True: bread = await self.queue.get() await asyncio.sleep(1) # eat slower, 1s/pc print(f’{self.consumer} eats {bread}’) self.queue.task_done()async def main(): queue = asyncio.Queue() cp1 = ConsumerProducerModel('John', 'Grace', queue) # group 1 cp2 = ConsumerProducerModel('Mike', 'Lucy', queue) # group 2 producer_1 = cp1.produce_bread() producer_2 = cp2.produce_bread() consumer_1 = asyncio.ensure_future(cp1.consume_bread()) consumer_2 = asyncio.ensure_future(cp2.consume_bread()) await asyncio.gather(*[producer_1, producer_2]) await queue.join() consumer_1.cancel() consumer_2.cancel()if __name__ == ’__main__’: loop = asyncio.get_event_loop() loop.run_until_complete(main()) loop.close()

生產消費者模型可以使用多線程和隊列來實現,這里選擇協程不僅是因為性能不錯,而且整個下來邏輯清晰:

1. 先定義初始化的東西,要有個隊列,要有生產者,要有消費者,要有裝面包的盤子大小;

2. 生產者:根據盤子大小生產出對應的東西(面包),將東西放入盤子(queue);

3. 消費者:從盤子上取東西,每次取東西都是一個任務,每次任務完成,就標記為task_done(調用函數)。在這個層面,一直循環;

4. 主邏輯:實例化生產消費者模型對象,創建生產者協程,創建任務(ensure_future),收集協程結果,等待所有線程結束(join),手動取消兩個消費者協程;

5. 運行:首先創建事件循環,然后進入主邏輯,直到完成,關閉循環。

到此這篇關于Python Asyncio模塊實現的生產消費者模型的方法的文章就介紹到這了,更多相關Python生產消費者模型內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Python 編程
相關文章:
主站蜘蛛池模板: KBX-220倾斜开关|KBW-220P/L跑偏开关|拉绳开关|DHJY-I隔爆打滑开关|溜槽堵塞开关|欠速开关|声光报警器-山东卓信有限公司 | 深圳工程师职称评定条件及流程_深圳职称评审_职称评审-职称网 | 浙江红酒库-冰雕库-气调库-茶叶库安装-医药疫苗冷库-食品物流恒温恒湿车间-杭州领顺实业有限公司 | 电动球阀_不锈钢电动球阀_电动三通球阀_电动调节球阀_上海湖泉阀门有限公司 | 雪花制冰机(实验室雪花制冰机)百科 | 注塑机-压铸机-塑料注塑机-卧式注塑机-高速注塑机-单缸注塑机厂家-广东联升精密智能装备科技有限公司 | 捆扎机_气动捆扎机_钢带捆扎机-沈阳海鹞气动钢带捆扎机公司 | 合金耐磨锤头_破碎机锤头_郑州市德勤建材有限公司 | 本安接线盒-本安电路用接线盒-本安分线盒-矿用电话接线盒-JHH生产厂家-宁波龙亿电子科技有限公司 | 活性氧化铝球|氧化铝干燥剂|分子筛干燥剂|氢氧化铝粉-淄博同心材料有限公司 | 喷漆房_废气处理设备-湖北天地鑫环保设备有限公司 | 风淋室生产厂家报价_传递窗|送风口|臭氧机|FFU-山东盛之源净化设备 | 哈尔滨治「失眠/抑郁/焦虑症/精神心理」专科医院排行榜-京科脑康免费咨询 一对一诊疗 | 山东太阳能路灯厂家-庭院灯生产厂家-济南晟启灯饰有限公司 | FFU_空气初效|中效|高效过滤器_空调过滤网-广州梓净净化设备有限公司 | 电子巡更系统-巡检管理系统-智能巡检【金万码】 | 北京康百特科技有限公司-分子蒸馏-短程分子蒸馏设备-实验室分子蒸馏设备 | 设计圈 - 让设计更有价值!| 重庆中专|职高|技校招生-重庆中专招生网 | 武汉EPS线条_EPS装饰线条_EPS构件_湖北博欧EPS线条厂家 | 电表箱-浙江迈峰电力设备有限公司-电表箱专业制造商 | 上海防爆真空干燥箱-上海防爆冷库-上海防爆冷柜?-上海浦下防爆设备厂家? | 偏心半球阀-电动偏心半球阀-调流调压阀-旋球阀-上欧阀门有限公司 | 无线遥控更衣吊篮_IC卡更衣吊篮_电动更衣吊篮配件_煤矿更衣吊篮-力得电子 | 仪器仪表网 - 永久免费的b2b电子商务平台 | 影像测量仪_三坐标测量机_一键式二次元_全自动影像测量仪-广东妙机精密科技股份有限公司 | 黄石妇科医院_黄石东方女子医院_黄石东方妇产医院怎么样 | 皮带式输送机械|链板式输送机|不锈钢输送机|网带输送机械设备——青岛鸿儒机械有限公司 | 茅茅虫AI论文写作助手-免费AIGC论文查重_写毕业论文降重 | 冷凝锅炉_燃气锅炉_工业燃气锅炉改造厂家-北京科诺锅炉 | 七维官网-水性工业漆_轨道交通涂料_钢结构漆 | 水平垂直燃烧试验仪-灼热丝试验仪-漏电起痕试验仪-针焰试验仪-塑料材料燃烧检测设备-IP防水试验机 | 高压无油空压机_无油水润滑空压机_水润滑无油螺杆空压机_无油空压机厂家-科普柯超滤(广东)节能科技有限公司 | 依维柯自动挡房车,自行式国产改装房车,小型房车价格,中国十大房车品牌_南京拓锐斯特房车 - 南京拓锐斯特房车 | 3d打印服务,3d打印汽车,三维扫描,硅胶复模,手板,快速模具,深圳市精速三维打印科技有限公司 | 杭州标识标牌|文化墙|展厅|导视|户内外广告|发光字|灯箱|铭阳制作公司 - 杭州标识标牌|文化墙|展厅|导视|户内外广告|发光字|灯箱|铭阳制作公司 | 电动高尔夫球车|电动观光车|电动巡逻车|电动越野车厂家-绿友机械集团股份有限公司 | 四合院设计_四合院装修_四合院会所设计-四合院古建设计与建造中心1 | 档案密集架,移动密集架,手摇式密集架,吉林档案密集架-厂家直销★价格公道★质量保证 | 美能达分光测色仪_爱色丽分光测色仪-苏州方特电子科技有限公司 | 宏源科技-房地产售楼系统|线上开盘系统|售楼管理系统|线上开盘软件 |