python 生产者消费者模型

生产者消费者模型

[目的]

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

[组成要素】

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

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

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

[主要方法]

容器:q=queue.Queue()

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

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

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

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

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

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

每天进步一点点,多思考,多总结 版权声明:本文为CNblog博主「zaituzhong」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
原文地址:https://www.cnblogs.com/tingxin/p/12230528.html