首页 > 代码库 > gevent queue应用1
gevent queue应用1
1 # -*- coding:utf-8 -*- 2 #! /usr/bin/env python 3 ‘‘‘ 4 Created on 2014年9月2日 5 ‘‘‘ 6 import gevent 7 from gevent.queue import Queue 8 import random 9 from time import time10 11 start = time()12 13 links = Queue()14 15 def downloader(pthread):16 while not links.empty():17 link = links.get()18 gevent.sleep(random.randint(1,3))19 print("%s: picture %s has been downloaded!" % (pthread,link))20 print("%s‘s mm has been downloaded!" % pthread)21 22 def getLinks():23 for i in xrange(1,50):24 links.put_nowait("http://baidu.com/%s.jpg" % i)25 26 gevent.spawn(getLinks).join()27 28 gevent.joinall([29 gevent.spawn(downloader,‘pThread1‘),30 gevent.spawn(downloader,‘pThread2‘),31 gevent.spawn(downloader,‘pThread3‘),32 gevent.spawn(downloader,‘pThread4‘),33 gevent.spawn(downloader,‘pThread5‘),34 gevent.spawn(downloader,‘pThread6‘),35 ])36 37 end = time()38 39 print("cost of time:",end-start)
gevent queue应用1
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。