Python Asyncio模块实现的生产消费者模型的方法_Python

asyncio的关键字说明

event_loop事件循环：程序开启一个无限循环，把一些函数注册到事件循环上，当满足事件发生的时候，调用相应的协程函数
coroutine协程：协程对象，指一个使用async关键字定义的函数，它的调用不会立即执行函数，而是会返回一个协程对象，协程对象需要注册到事件循环，由事件循环调用。
task任务：一个协程对象就是一个原生可以挂起的函数，任务则是对协程进一步封装，其中包含了任务的各种状态
future:代表将来执行或没有执行的任务结果。它和task上没有本质上的区别
async/await关键字:async定义一个协程，await用于挂起阻塞的异步调用接口，在python3.4是使用asyncio.coroutine/yield from

在设计模式中，生产消费者模型占有非常重要的地位，这个模型在现实世界中也有很多有意思的对应场景，比如做包子的人和吃包子的人，当两者速度不匹配时，就需要有一个模型来做匹配（偶合），实现做的包子都会依次消费掉。

				?

									import asyncio

									class 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()