本文实例讲述了python基于queue和threading实现多线程下载的方法，分享给大家供大家参考。具体方法如下：
主代码如下：
#download worker
queue_download = queue.queue(0)
download_workers = 20
for i in range(download_workers):
downloadworker(queue_download).start() #start a download worker
for md5 in md5s:
queue_download.put(md5)
for i in range(download_workers):
queue_download.put(none)
其中downloadworkers.py
类继承 threading.thread,重载run方法..在__init__中调用threading.thread.__init__(self),
在run方法中实现耗时的操作
import threading
import queue
import md5query
import dom
import os,sys
class downloadworker(threading.thread):
“”””””
def __init__(self, queue):
“””constructor”””
self.__queue = queue
threading.thread.__init__(self)
def run(self):
while 1:
md5 = self.__queue.get()
if md5 is none:
break #reached end of queue
#this is a time-cost produce
self._down(md5)
print “task:”, md5, “finished”
def _down(self, md5):
config = {
‘input’:sys.stdin,
‘output’:’./samples’,
‘location’:’xxx’,
‘has-fn’:false,
‘options’:{‘connect.timeout’:60, ‘timeout’:3600},
‘log’:file(‘logs.txt’, ‘w’),
}
print ‘download %s…’ % (md5)
try:
data = downloadproc(config[‘location’], config[‘options’])#我的下载过程
if data:
dom, filedata = md5query.splited(data)
filename = md5
if config[‘has-fn’]:
filename = ‘%s_%s’ % (md5, dom.nodevalue2(‘xxxxxxx’, ”).encode(‘utf-8’))#这是我的下载的方法
f = file(os.path.join(config[‘output’], filename), ‘w’)
f.write(filedata)
f.close()
print ‘%s\tok’ % (md5)
else:
print>>config[‘log’], ‘%s\t%s’ % (md5, ‘failed’)
except exception, e:
print>>config[‘log’], ‘%s\t%s’ % (md5, str(e))
希望本文所述对大家的python程序设计有所帮助。