Cleaner consumers

2014-07-17 12:01:04 +02:00 · 2014-07-17 12:01:04 +02:00 · a8ce37a372
commit a8ce37a372
parent e5741ce1cb
2 changed files with 11 additions and 9 deletions
--- a/consumer.py
+++ b/consumer.py
@ -136,8 +136,10 @@ class Consumer(threading.Thread):
            while not self.stop:
                stm = self.context.cnsr_queue.get(True, 20)
                stm.run(self.context)
+                self.context.cnsr_queue.task_done()

        except queue.Empty:
            pass
        finally:
            self.context.cnsr_thrd_size -= 2
+            self.context.cnsr_thrd.remove(self)