线程案例：生产者与消费者

你的名字 2022-03-08 09:16 291阅读 0赞

> 在线程世界里，生产者就是生产数据的线程，消费者就是消费数据的线程。  
> 在多线程开发当中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。  
> 同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。  
> 为了解决这种生产消费能力不均衡的问题，所以便有了生产者和消费者模式  
> 生产者和消费者彼此之间不直接通讯，而通过阻塞队列来进行通讯，所以生产者生产完数据之后  
> 不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列里取，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力。  
> 这就像，在餐厅，厨师做好菜，不需要直接和客户交流，而是交给前台，而客户去饭菜也不需要不找厨师，直接去前台领取即可。

--------------------- 
    
    from  queue import Queue
    from  threading import  Thread
    import  time
    q=Queue(maxsize=10)
    #生产者
    def cooker(name):
        count=1
        while True:
            q.put('包子%d'%count)
            print('%s生产了包子%d'%(name,count))
            count+=1
    #消费者
    def consumer(name):
        while True:
            print('{}吃了包子{}'.format(name,q.get()))
    if __name__ == '__main__':
        cooker1=Thread(target=cooker,args=('刘争',))
        cooker1.start()
        gk1=Thread(target=consumer,args=('小小争',))
        gk1.start()
        gk2 = Thread(target=consumer, args=('小争争',))
        gk2.start()