解释
成都创新互联公司专注于企业营销型网站、网站重做改版、包河网站定制设计、自适应品牌网站建设、H5高端网站建设、购物商城网站建设、集团公司官网建设、成都外贸网站建设公司、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为包河等各大城市提供网站开发制作服务。
什么是生产者和消费者？
两个模块（可能是函数、线程或进程），一个生产数据，一个消费数据，生产数据的模块叫生产者，消费数据的模块叫消费者。
为什么要使用生产者-消费者模式？
在多线程开发时，生产者可能产生数据的速度比较快，这时候生产者需要等消费者消费完了才能继续生产数据，因为生产的数据没地方放，如果消费者消费数据的速度比较快，消费者就要等待生产者生产数据，为了解决这种供需不平衡的问题，以达到生产者和消费者之间的一种“平衡”状态，引入“生产者-消费者“模式
什么是生产者消费者模式？
一个生产者（线程或进程）生产数据，一个消费者（线程或进程）消费数据，它们之间通过一个缓冲区来进行通讯，生产者生产的数据放入缓冲区，消费者从缓冲区取来数据进行消费。
生产者消费者模式有什么优点？
redis的list作为队列，而消费者只需要轮询队列中是否有数据。同时还能支持集群的伸缩性，当某台机器宕掉的时候，不会导致整个集群宕掉生产者消费者例子
e.g.
5个厨师做包子，三秒一个，10个食客吃包子，1秒一个，食客吃的又快人又多
import queue
import threading
import time
q = queue.Queue()
def cook(i):
while True:
q.put(f'厨师{i}做de包子')
time.sleep(2)
def hangers_on(j):
while True:
print(f'食客{j}吃了{q.get()}')
time.sleep(1)
for i in range(5):
threading.Thread(target=cook,args=(i,)).start()
for j in range(10):
threading.Thread(target=hangers_on,args=(j,)).start()
用协程实现同样的例子
q = asyncio.Queue()
async def hangers_on(j):
while True:
print(f'食客{j}吃了{await q.get()}')
await asyncio.sleep(3)
async def cook(i):
while True:
print(f'厨师{i}做的包子')
await q.put(f'厨师{i}做的包子')
await asyncio.sleep(1)
async def main():
cook_tasks = [asyncio.create_task(cook(j)) for j in range(10)]
hanges_tasks = [asyncio.create_task(hangers_on(i)) for i in range(10)]
await asyncio.gather(*cook_tasks,*hanges_tasks,return_exceptions = True)
asyncio.run(main())
