Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import os
- import datetime
- from threading import Thread
- from Queue import Queue, Empty
- import sys
- class mseed2sac():
- def __init__(self):
- self.start_time = datetime.datetime.now()
- #self.path = 'd:\\test\\mseed\\2015\\103'
- self.path = "/tmp"
- 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:
- print "#{0} q.empty()={1}".format(i, q.empty())
- if q.empty():
- #sys.exit()
- break
- try:
- cmd = q.get(False)
- except Empty:
- break
- #print cmd
- def main(self):
- result = os.listdir(self.path)
- num_threads = 10
- q = Queue()
- print "------- starting DO_mseed2sac -------"
- for i in result:
- tmp = i.split("-")
- if len(tmp) == 3 and len(tmp[2]) > 2:
- cmd = 'mseed2sac %s'%(
- os.path.join(self.path, tmp[2]))
- 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()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement