SickRage/sickbeard/event_queue.py

import threading
from Queue import Queue, Empty

class Event:
    def __init__(self, type):
        self._type = type

    @property
    def type(self):
        return self._type

class Events(threading.Thread):
    def __init__(self, callback):
        super(Events, self).__init__()
        self.queue = Queue()
        self.daemon = True
        self.callback = callback
        self.name = "EVENT-QUEUE"
        self.stop = threading.Event()

    def put(self, type):
        self.queue.put(type)

    def run(self):
        while (not self.stop.is_set()):
            try:
                # get event type
                type = self.queue.get(True, 1)

                # perform callback if we got a event type
                self.callback(type)

                # event completed
                self.queue.task_done()
            except Empty:
                type = None

        # exiting thread
        self.stop.clear()

    # System Events
    class SystemEvent(Event):
        RESTART = "RESTART"
        SHUTDOWN = "SHUTDOWN"