首页 > 自动化运维 > python > Python消息队列
2015
10-13

Python消息队列

一、生产者消费者模型代码

#!/usr/bin/env python
#coding=utf8
import threading,time
import Queue,random
#消息队列
q = Queue.Queue()
#生成者
def Producer(name):
        for i in range(20):
#添加到队列中去
                q.put(i)
                print '\033[32;1mProducer %s has made %s 烧饼\033[0m' % (name,i)
#使用random生成一个随机数
                time.sleep(random.randrange(2))
#消费者
def Consumer(name):
        count = 0
        while count < 20:
#从队列中取出数据
                date = q.get()
                print '\033[31;1mConsumer %s has eaten %s 烧饼...chihuo...\033[0m' %(name,date)
                count +=1
                time.sleep(random.randrange(1))

#使用多线程
p = threading.Thread(target=Producer, args=('武大郎',))
c = threading.Thread(target=Consumer, args=('西门庆',))
p.start()
c.start()

二、执行效果展示

blob.png




最后编辑:
作者:tshare365
这个作者貌似有点懒,什么都没有留下。
捐 赠您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请狠狠点击

留下一个回复