import os
import datetime
from threading import Thread
from Queue import Queue
import sys

class mseed2sac():

　　def __init__(self):

　　　　self.start_time = datetime.datetime.now()

　　　　self.path = 'd:\\test\\mseed\\2015\\103'
　　　　self.main()

　　　　self.end_time = datetime.datetime.now()
　　　　print "start time", self.start_time
　　　　print "end time", self.end_time

　　def DO_mseed2sac(self,i,q):

　　　　while True:
　　　　　　if q.empty():
　　　　　　　　sys.exit()

　　　　　　cmd = q.get()
　　　　　　print cmd

　　def main(self):

　　　　result = os.popen('dir %s'%self.path)

　　　　num_threads = 10
　　　　q = Queue()

　　　　print "------- starting DO_mseed2sac -------"

　　　　for i in result:
　　　　　　tmp = i.split()
　　　　　　if len(tmp) == 5 and len(tmp[4]) > 2:
　　　　　　　　cmd = 'mseed2sac %s\\%s'%(self.path,tmp[4])
　　　　　　　　q.put(cmd)

　　　　for i in range(num_threads):
　　　　　　worker = Thread(target=self.DO_mseed2sac, args=(i, q))
　　　　　　worker.setDaemon(True)
　　　　　　worker.start()

　　　　worker.join()

if __name__=='__main__':
　　mseed2sac()