详解Python 模拟实现生产者消费者模式的实例
详解Python模拟实现生产者消费者模式的实例
散仙使用python3.4模拟实现的一个生产者与消费者的例子，用到的知识有线程，队列，循环等，源码如下：
Python代码
importqueue
importtime
importthreading
importrandom
q=queue.Queue(5)
#生产者
defpr():
name=threading.current_thread().getName()
print(name+"线程启动......")
foriinrange(100):
t=random.randint(2,9)
print(name,"睡眠时间:",t)
time.sleep(t);
d="A"+str(i)
print(name+"正在存第",i+1,"个数据:",d)
#q.put("A"+str(i),False,2000)
q.put(d)
print("生产完毕!")
#消费者
defco():
name=threading.current_thread().getName()
time.sleep(1)
print(name+"线程启动......")
whileTrue:
print(name+"检测到队列数量:",q.qsize())
t=random.randint(2,9)
print(name,"睡眠时间:",t)
data=q.get();
print(name+"消费一个数据:",data)
p=threading.Thread(target=pr,name="生产者")
c=threading.Thread(target=co,name="消费者1")
c2=threading.Thread(target=co,name="消费者2")
p.start()
c.start()
c2.start()
在本例里面散仙启动了1个生产者线程，2个消费者线程，打印效果如下：
Python代码
生产者线程启动...... 生产者睡眠时间:4 消费者1线程启动...... 消费者1检测到队列数量:0 消费者1睡眠时间:2 消费者2线程启动...... 消费者2检测到队列数量:0 消费者2睡眠时间:3 生产者正在存第1个数据:A0 生产者睡眠时间:9 消费者1消费一个数据:A0 消费者1检测到队列数量:0 消费者1睡眠时间:8 生产者正在存第2个数据:A1 生产者睡眠时间:5 消费者2消费一个数据:A1 消费者2检测到队列数量:0 消费者2睡眠时间:7 生产者正在存第3个数据:A2 生产者睡眠时间:8 消费者1消费一个数据:A2 消费者1检测到队列数量:0 消费者1睡眠时间:2 生产者正在存第4个数据:A3 生产者睡眠时间:7 消费者2消费一个数据:A3 消费者2检测到队列数量:0 消费者2睡眠时间:9 生产者正在存第5个数据:A4 生产者睡眠时间:2 消费者1消费一个数据:A4 消费者1检测到队列数量:0 消费者1睡眠时间:5 生产者正在存第6个数据:A5 生产者睡眠时间:5 消费者2消费一个数据:A5 消费者2检测到队列数量:0 消费者2睡眠时间:6 生产者正在存第7个数据:A6 生产者睡眠时间:7 消费者1消费一个数据:A6 消费者1检测到队列数量:0 消费者1睡眠时间:7 生产者正在存第8个数据:A7 生产者睡眠时间:3 消费者2消费一个数据:A7 消费者2检测到队列数量:0 消费者2睡眠时间:8 生产者正在存第9个数据:A8 生产者睡眠时间:2 消费者1消费一个数据:A8 消费者1检测到队列数量:0 消费者1睡眠时间:4 生产者正在存第10个数据:A9 生产者睡眠时间:4 消费者2消费一个数据:A9 消费者2检测到队列数量:0 消费者2睡眠时间:5 生产者正在存第11个数据:A10 生产者睡眠时间:2 消费者1消费一个数据:A10 消费者1检测到队列数量:0 消费者1睡眠时间:3 生产者正在存第12个数据:A11 生产者睡眠时间:3 消费者2消费一个数据:A11 消费者2检测到队列数量:0 消费者2睡眠时间:3 生产者正在存第13个数据:A12 生产者睡眠时间:3 消费者1消费一个数据:A12 消费者1检测到队列数量:0 消费者1睡眠时间:3 生产者正在存第14个数据:A13 生产者睡眠时间:8 消费者2消费一个数据:A13 消费者2检测到队列数量:0 消费者2睡眠时间:7 生产者正在存第15个数据:A14 生产者睡眠时间:3 消费者1消费一个数据:A14 消费者1检测到队列数量:0 消费者1睡眠时间:7 生产者正在存第16个数据:A15 生产者睡眠时间:2 消费者2消费一个数据:A15 消费者2检测到队列数量:0 消费者2睡眠时间:9
从这个例子中，我们发现利用队列，来做同步时非常简单方便的，除此之外队列，还有如下几个方便的方法：
介绍一下此包中的常用方法:
Queue.qsize()返回队列的大小 Queue.empty()如果队列为空，返回True,反之False Queue.full()如果队列满了，返回True,反之False Queue.full与maxsize大小对应 Queue.get([block[,timeout]])获取队列，timeout等待时间 Queue.get_nowait()相当Queue.get(False) 非阻塞Queue.put(item)写入队列，timeout等待时间 Queue.put_nowait(item)相当Queue.put(item,False) Queue.task_done()在完成一项工作之后，Queue.task_done()函数向任务已经完成的队列发送一个信号 Queue.join()实际上意味着等到队列为空，再执行别的操作
以上就是详解Python模拟实现生产者消费者模式的实例，如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！