def run(self): while not self.stopped(): try: self.q.get(False) self.q.task_done() except Queue.Empty: pass pass