使用Python多线程实现生产者与消费者模型

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用Python多线程实现生产者与消费者模型相关的知识,希望对你有一定的参考价值。

1,我所使用到的python版本
技术分享图片

2,下面编写具体的实现过程

import threading
import time
import Queue

#首先生成一个队列
q =Queue.Queue()

#生产者
def producer(name):
l=threading.Rlock()
for i in range(40):
l.acquire()
q.put(i)
l.release()
print "this is thead name is %s ,produce num is %s" %(name,i)
time.sleep(2)

#消费者
def consumer(name):
count =0
while count <=20:
resulte =q.get()
print ‘the thread name is %s and the consume num is %s‘ %(name,result)
time.sleep(4)

#测试
for i in range(10):
p = threading.Thread(target=producer,args=(‘xxxx‘,))
p.start()

        c =threading.Thread(target=consumer,args=(‘yyyy‘,))
        c.start()

以上是关于使用Python多线程实现生产者与消费者模型的主要内容,如果未能解决你的问题,请参考以下文章

Java多线程与并发库4.传统线程同步通信技术

11.python并发入门(part8 基于线程队列实现生产者消费者模型)

Linux:详解多线程(线程同步信号量和生产者与消费者模型的实现)

Linux:详解多线程(线程同步信号量和生产者与消费者模型的实现)

Python 生产者与消费者模型

多线程生产者消费者模型