class DownloadWeather(Thread): def__init__(self, path, url, num_of_workers=5, timeout = 2):
Thread.__init__(self)
self.path = path
self.url = url
#self.city = city
def run(self):
#use command "curl" download data from sina.com.cn
os.popen("/usr/local/bin/curl --limit-rate 200k --compressed -s -o %s -e %s"%(self.path, self.url))
time1=time.time()
f = open("/var/www/weather/city.txt") for city in f.readlines():
city=city.strip()
wtime=str(time.time())[:10]
path='/var/www/weather/data/'+ city
url=' '+city+'&time='+wtime
# an instance of class DownloadWeather
mydownload=DownloadWeather(path,url)
#mydownload=DownloadWeather(path,city,wtime)
mydownload.setDaemon(1)
mydownload.start()
mydownload.join()
f.close() print(time.time()- time1)