首页 > 代码库 > python多线程队列使用
python多线程队列使用
#线程1 -> 队列 -> 线程2 -> url_web
#
#
#
#!/usr/bin/env python #! coding=utf-8 #!by=xiaohe import Queue,threading,time,random from moniItems import mon import urllib2 from flask import Flask,request,json queueLock = threading.Lock() class t1(threading.Thread): def __init__(self,t_name,queue): threading.Thread.__init__(self,name=t_name) self.data = queue def run(self): #for i in range(5): while True: queueLock.acquire() if self.data.empty(): print time.ctime(),self.getName() self.data.put(mon().runAllGet()) time.sleep(1) queueLock.release() else: queueLock.release() #print time.ctime(),self.getName(),"end" class t2(threading.Thread): def __init__(self,t_name,queue): threading.Thread.__init__(self,name=t_name) self.data=http://www.mamicode.com/queue"http://reboot:8088", json.dumps(vai), {‘Content-Type‘: ‘application/json‘}) urllib2.urlopen(a) queueLock.release() else: queueLock.release() def mai(): queue = Queue.Queue(5) tt1 = t1(‘shou‘,queue) tt2 = t2(‘fa‘,queue) tt1.start() tt2.start() tt1.join() tt2.join() if __name__==‘__main__‘: mai()
本文出自 “小盒” 博客,请务必保留此出处http://zhangxiaohe.blog.51cto.com/7821029/1571305
python多线程队列使用
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。