python中利用队列asyncio.Queue进行通讯详解
前言
本文主要给大家介绍了关于python用队列asyncio.Queue通讯的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧。
asyncio.Queue与其它队列是一样的,都是先进先出,它是为协程定义的
例子如下:
importasyncio asyncdefconsumer(n,q): print('consumer{}:starting'.format(n)) whileTrue: print('consumer{}:waitingforitem'.format(n)) item=awaitq.get() print('consumer{}:hasitem{}'.format(n,item)) ifitemisNone: #Noneisthesignaltostop. q.task_done() break else: awaitasyncio.sleep(0.01*item) q.task_done() print('consumer{}:ending'.format(n)) asyncdefproducer(q,num_workers): print('producer:starting') #Addsomenumberstothequeuetosimulatejobs foriinrange(num_workers*3): awaitq.put(i) print('producer:addedtask{}tothequeue'.format(i)) #AddNoneentriesinthequeue #tosignaltheconsumerstoexit print('producer:addingstopsignalstothequeue') foriinrange(num_workers): awaitq.put(None) print('producer:waitingforqueuetoempty') awaitq.join() print('producer:ending') asyncdefmain(loop,num_consumers): #Createthequeuewithafixedsizesotheproducer #willblockuntiltheconsumerspullsomeitemsout. q=asyncio.Queue(maxsize=num_consumers) #Scheduledtheconsumertasks. consumers=[ loop.create_task(consumer(i,q)) foriinrange(num_consumers) ] #Scheduletheproducertask. prod=loop.create_task(producer(q,num_consumers)) #Waitforallofthecoroutinestofinish. awaitasyncio.wait(consumers+[prod]) event_loop=asyncio.get_event_loop() try: event_loop.run_until_complete(main(event_loop,2)) finally: event_loop.close()
输出如下:
consumer0:starting consumer0:waitingforitem consumer1:starting consumer1:waitingforitem producer:starting producer:addedtask0tothequeue producer:addedtask1tothequeue consumer0:hasitem0 consumer1:hasitem1 producer:addedtask2tothequeue producer:addedtask3tothequeue consumer0:waitingforitem consumer0:hasitem2 producer:addedtask4tothequeue consumer1:waitingforitem consumer1:hasitem3 producer:addedtask5tothequeue producer:addingstopsignalstothequeue consumer0:waitingforitem consumer0:hasitem4 consumer1:waitingforitem consumer1:hasitem5 producer:waitingforqueuetoempty consumer0:waitingforitem consumer0:hasitemNone consumer0:ending consumer1:waitingforitem consumer1:hasitemNone consumer1:ending producer:ending
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对毛票票的支持。