schedulerThread.py

import sys
import threading
import logging

class EventScheduler(threading.Thread):
    def __init__(self, event_callback, interval):
        logging.info("creating scheduler")
        super(EventScheduler, self).__init__()
        self.setDaemon(True)
        self.event_callback = event_callback
        self.interval = int(interval)
 
    def run(self):
        logging.info("Scheduler Created")
        while True:
            try:
                self.event_callback()
            except Exception as e:
                logging.error(str(e))
            time.sleep(self.interval)
            
            
# Usage
def my_callback():
  print "callback called"
scheduler = EventScheduler(my_callback, 5)
scheduler.start()
while True:
  sys.sleep(1) # daemon