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

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

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

瀏覽:109日期: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 編程
相關文章:
主站蜘蛛池模板: 电伴热系统施工_仪表电伴热保温箱厂家_沃安电伴热管缆工业技术(济南)有限公司 | 蓝莓施肥机,智能施肥机,自动施肥机,水肥一体化项目,水肥一体机厂家,小型施肥机,圣大节水,滴灌施工方案,山东圣大节水科技有限公司官网17864474793 | 西安标准厂房_陕西工业厂房_西咸新区独栋厂房_长信科技产业园官方网站 | 外观设计_设备外观设计_外观设计公司_产品外观设计_机械设备外观设计_东莞工业设计公司-意品深蓝 | 耐高温风管_耐高温软管_食品级软管_吸尘管_钢丝软管_卫生级软管_塑料波纹管-东莞市鑫翔宇软管有限公司 | 查分易-成绩发送平台官网 | 洁净实验室工程-成都手术室净化-无尘车间装修-四川华锐净化公司-洁净室专业厂家 | 上海噪音治理公司-专业隔音降噪公司-中广通环保 | 杭州货架订做_组合货架公司_货位式货架_贯通式_重型仓储_工厂货架_货架销售厂家_杭州永诚货架有限公司 | 网站建设,北京网站建设,北京网站建设公司,网站系统开发,北京网站制作公司,响应式网站,做网站公司,海淀做网站,朝阳做网站,昌平做网站,建站公司 | 水冷式工业冷水机组_风冷式工业冷水机_水冷螺杆冷冻机组-深圳市普威机械设备有限公司 | 仿真茅草_人造茅草瓦价格_仿真茅草厂家_仿真茅草供应-深圳市科佰工贸有限公司 | 粉末包装机-给袋式包装机-全自动包装机-颗粒-液体-食品-酱腌菜包装机生产线【润立机械】 | PE一体化污水处理设备_地埋式生活污水净化槽定制厂家-岩康塑业 | 钢衬玻璃厂家,钢衬玻璃管道 -山东东兴扬防腐设备有限公司 | 铝板冲孔网,不锈钢冲孔网,圆孔冲孔网板,鳄鱼嘴-鱼眼防滑板,盾构走道板-江拓数控冲孔网厂-河北江拓丝网有限公司 | 高铝砖-高铝耐火球-高铝耐火砖生产厂家-价格【荣盛耐材】 | 2025黄道吉日查询、吉时查询、老黄历查询平台- 黄道吉日查询网 | Jaeaiot捷易科技-英伟达AI显卡模组/GPU整机服务器供应商 | 软膜天花_软膜灯箱_首选乐创品牌_一站式天花软膜材料供应商! | 氟氨基酮、氯硝柳胺、2-氟苯甲酸、异香兰素-新晨化工 | 间甲酚,间甲酚厂家-山东祥东新材料 | 动物麻醉机-数显脑立体定位仪-北京易则佳科技有限公司 | 破碎机锤头_耐磨锤头_合金锤头-鼎成机械一站式耐磨铸件定制服务 微型驱动系统解决方案-深圳市兆威机电股份有限公司 | 滁州高低温冲击试验箱厂家_安徽高低温试验箱价格|安徽希尔伯特 | 瑞典Blueair空气净化器租赁服务中心-专注新装修办公室除醛去异味服务! | 海日牌清洗剂-打造带电清洗剂、工业清洗剂等清洗剂国内一线品牌 海外整合营销-独立站营销-社交媒体运营_广州甲壳虫跨境网络服务 | 在线钠离子分析仪-硅酸根离子浓度测定仪-油液水分测定仪价格-北京时代新维测控设备有限公司 | 实木家具_实木家具定制_全屋定制_美式家具_圣蒂斯堡官网 | 昆明化妆培训-纹绣美甲-美容美牙培训-昆明博澜培训学校 | 大型工业风扇_工业大风扇_大吊扇_厂房车间降温-合昌大风扇 | 自动化生产线-自动化装配线-直流电机自动化生产线-东莞市慧百自动化有限公司 | 肉嫩度仪-凝胶测试仪-国产质构仪-气味分析仪-上海保圣实业发展有限公司|总部 | EFM 022静电场测试仪-套帽式风量计-静电平板监测器-上海民仪电子有限公司 | 防水套管_柔性防水套管_刚性防水套管-巩义市润达管道设备制造有限公司 | 中央空调温控器_风机盘管温控器_智能_液晶_三速开关面板-中央空调温控器厂家 | 气体检测仪-氢气检测仪-可燃气体传感器-恶臭电子鼻-深国安电子 | 全自动实验室洗瓶机,移液管|培养皿|进样瓶清洗机,清洗剂-广州摩特伟希尔机械设备有限责任公司 | 贝壳粉涂料-内墙腻子-外墙腻子-山东巨野七彩贝壳漆业中心 | LNG鹤管_内浮盘价格,上装鹤管,装车撬厂家-连云港赛威特机械 | 耐力板-PC阳光板-PC板-PC耐力板 - 嘉兴赢创实业有限公司 |