生产者消费者模型

Posted 2021-03-14 tingxin

生产者消费者模型

[目的]

解决并发编程中的绝大部分并发问题

【组成要素】

生产者：负责生产数据或任务

消费者：负责消费数据或者任务

容器：生产者和消费者进行通讯的媒介（阻塞队列）来达到解耦目的

[主要方法]

容器：q=queue.Queue()

生产者：q.put(product/tack)

　　　　q.jion() 阻塞至队列中所有的元素都被接收和处理完毕。

　　　　　　　　当条目添加到队列的时候，未完成任务的计数就会增加。当未完成计数降到零的时候， join() 阻塞被解除。

消费者：q.get(product/tack) 获取一个任务

　　　　q.task_done() 表示前面排队的任务已经被完成

　　　　表示这个条目已经被回收，该条目所有工作已经完成，未完成计数就会减少。