'Process items in this queue'

def run(self):

    while (not self.stop.is_set()):
        with self.lock:
            self.amActive = True
            if ((self.currentItem is None) or (not self.currentItem.isAlive())):
                if self.currentItem:
                    self.currentItem = None
                self.currentItem = self.get()
                if (self.currentItem.priority < self.min_priority):
                    self.put(self.currentItem)
                    self.currentItem = None
                else:
                    self.currentItem.start()
                    self.threads += [self.currentItem]
            self.amActive = False
        time.sleep(1)
