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

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

Python多線程 Queue 模塊常見用法

瀏覽:4日期:2022-06-15 14:04:51
queue介紹

queue是python中的標準庫,俗稱隊列,可以直接import 引用,在python2.x中,模塊名為Queue在python中,多個線程之間的數據是共享的,多個線程進行數據交換的時候,不能夠保證數據的安全性和一致性,所以當多個線程需要進行數據交換的時候,隊列就出現了,隊列可以完美解決線程間的數據交換,保證線程間數據的安全性和一致性

Python 的 Queue 模塊中提供了同步的、線程安全的隊列類,包括FIFO(先入先出)隊列Queue,LIFO(后入先出)隊列LifoQueue,和優先級隊列 PriorityQueue。

這些隊列都實現了鎖原語,能夠在多線程中直接使用,可以使用隊列來實現線程間的同步。Queue 模塊中的常用方法:

Queue.qsize() 返回隊列的大小Queue.empty() 如果隊列為空,返回True,反之FalseQueue.full() 如果隊列滿了,返回True,反之FalseQueue.full 與 maxsize 大小對應Queue.get([block[, timeout]])獲取隊列,timeout等待時間Queue.get_nowait() 相當Queue.get(False)Queue.put(item) 寫入隊列,timeout等待時間Queue.put_nowait(item) 相當Queue.put(item, False)Queue.task_done() 在完成一項工作之后,Queue.task_done()函數向任務已經完成的隊列發送一個信號Queue.join() 實際上意味著等到隊列為空,再執行別的操作

import threadingimport timedef a(): print('a startn') for i in range(10):time.sleep(0.1) print('a finishn')def b(): print('b startn') print('b finishn')def main(): # t=threading.Thread(target=a,name='T') t = threading.Thread(target=a) t2=threading.Thread(target=b) t.start() t2.start() # t2.join() # t.join() print('all donen')if __name__ == ’__main__’: main()

Queue 模塊:

import queueimport threadingimport timeexitFlag = 0class myThread (threading.Thread): def __init__(self, threadID, name, q):threading.Thread.__init__(self)self.threadID = threadIDself.name = nameself.q = q def run(self):print ('開啟線程:' + self.name)process_data(self.name, self.q)print ('退出線程:' + self.name)def process_data(threadName, q): while not exitFlag:queueLock.acquire()if not workQueue.empty(): data = q.get() queueLock.release() print ('%s processing %s' % (threadName, data))else: queueLock.release()time.sleep(1)threadList = ['Thread-1', 'Thread-2', 'Thread-3']nameList = ['One', 'Two', 'Three', 'Four', 'Five']queueLock = threading.Lock()workQueue = queue.Queue(10)threads = []threadID = 1# 創建新線程for tName in threadList: thread = myThread(threadID, tName, workQueue) thread.start() threads.append(thread) threadID += 1# 填充隊列queueLock.acquire()for word in nameList: workQueue.put(word)queueLock.release()# 等待隊列清空while not workQueue.empty(): pass# 通知線程是時候退出exitFlag = 1# 等待所有線程完成for t in threads: t.join()print ('退出主線程')

到此這篇關于Python多線程 Queue 模塊的文章就介紹到這了,更多相關Python Queue 模塊內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Python 編程
相關文章:
主站蜘蛛池模板: LHH药品稳定性试验箱-BPS系列恒温恒湿箱-意大利超低温冰箱-上海一恒科学仪器有限公司 | 发电机组|柴油发电机组-批发,上柴,玉柴,潍柴,康明斯柴油发电机厂家直销 | 全自动不干胶贴标机_套标机-上海今昂贴标机生产厂家 | 泰来华顿液氮罐,美国MVE液氮罐,自增压液氮罐,定制液氮生物容器,进口杜瓦瓶-上海京灿精密机械有限公司 | 密集架-密集柜厂家-智能档案密集架-自动选层柜订做-河北风顺金属制品有限公司 | 土壤养分检测仪_肥料养分检测仪_土壤水分检测仪-山东莱恩德仪器 大型多片锯,圆木多片锯,方木多片锯,板材多片锯-祥富机械有限公司 | led全彩屏-室内|学校|展厅|p3|户外|会议室|圆柱|p2.5LED显示屏-LED显示屏价格-LED互动地砖屏_蕙宇屏科技 | 电动葫芦|环链电动葫芦-北京凌鹰名优起重葫芦 | led冷热冲击试验箱_LED高低温冲击试验箱_老化试验箱-爱佩百科 | 超细粉碎机|超微气流磨|气流分级机|粉体改性设备|超微粉碎设备-山东埃尔派粉碎机厂家 | 细砂提取机,隔膜板框泥浆污泥压滤机,螺旋洗砂机设备,轮式洗砂机械,机制砂,圆锥颚式反击式破碎机,振动筛,滚筒筛,喂料机- 上海重睿环保设备有限公司 | 智成电子深圳tdk一级代理-提供TDK电容电感贴片蜂鸣器磁芯lambda电源代理经销,TDK代理商有哪些TDK一级代理商排名查询。-深圳tdk一级代理 | 煤矿人员精确定位系统_矿用无线通信系统_煤矿广播系统 | 劳动法网-专业的劳动法和劳动争议仲裁服务网 | 铁素体测量仪/检测仪/铁素体含量测试仪-苏州圣光仪器有限公司 | 高楼航空障碍灯厂家哪家好_航空障碍灯厂家_广州北斗星障碍灯有限公司 | 语料库-提供经典范文,文案句子,常用文书,您的写作得力助手 | 上海诺狮景观规划设计有限公司| 成都热收缩包装机_袖口式膜包机_高速塑封机价格_全自动封切机器_大型套膜机厂家 | 热缩管切管机-超声波切带机-织带切带机-无纺布切布机-深圳市宸兴业科技有限公司 | 北京企业宣传片拍摄_公司宣传片制作-广告短视频制作_北京宣传片拍摄公司 | 头条搜索极速版下载安装免费新版,头条搜索极速版邀请码怎么填写? - 欧远全 | 防伪溯源|防窜货|微信二维码营销|兆信_行业内领先的防伪防窜货数字化营销解决方案供应商 | 量子管通环-自清洗过滤器-全自动反冲洗过滤器-北京罗伦过滤技术集团有限公司 | 中宏网-今日新闻-财经新闻 | 免费网站网址收录网_海企优网站推荐平台| 北京三友信电子科技有限公司-ETC高速自动栏杆机|ETC机柜|激光车辆轮廓测量仪|嵌入式车道控制器 | 深圳市人通智能科技有限公司| 多功能干燥机,过滤洗涤干燥三合一设备-无锡市张华医药设备有限公司 | 温州中研白癜风专科_温州治疗白癜风_温州治疗白癜风医院哪家好_温州哪里治疗白癜风 | 老房子翻新装修,旧房墙面翻新,房屋防水补漏,厨房卫生间改造,室内装潢装修公司 - 一修房屋快修官网 | 即用型透析袋,透析袋夹子,药敏纸片,L型涂布棒-上海桥星贸易有限公司 | 西安烟道厂家_排气道厂家_包立管厂家「陕西西安」推荐西安天宇烟道 | 上海地磅秤|电子地上衡|防爆地磅_上海地磅秤厂家–越衡称重 | 福建珂朗雅装饰材料有限公司「官方网站」 | 成都竞价托管_抖音代运营_网站建设_成都SEM外包-成都智网创联网络科技有限公司 | 泥浆在线密度计厂家-防爆数字压力表-膜盒-远传压力表厂家-江苏大亚自控设备有限公司 | 丹佛斯变频器-丹佛斯压力开关-变送器-广州市风华机电设备有限公司 | 安平县鑫川金属丝网制品有限公司,防风抑尘网,单峰防风抑尘,不锈钢防风抑尘网,铝板防风抑尘网,镀铝锌防风抑尘网 | 江苏农村商业银行招聘网_2024江苏农商行考试指南_江苏农商行校园招聘 | 三防漆–水性三防漆–水性浸渍漆–贝塔三防漆厂家 |