Debug for https://www.facebook.com/groups/pythontw/permalink/10153903302848438/

mseed2sac.py

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()