Accelerate shutdown

This commit is contained in:
nemunaire 2015-09-02 07:12:51 +02:00
parent f66ed07496
commit b66d7d30ed

View File

@ -231,7 +231,7 @@ class Consumer(threading.Thread):
def run(self):
try:
while not self.stop:
stm = self.context.cnsr_queue.get(True, 10)
stm = self.context.cnsr_queue.get(True, 1)
stm.run(self.context)
self.context.cnsr_queue.task_done()