Merge "Handle task manager shutdown more correctly"

This commit is contained in:
Jenkins 2014-06-26 19:14:32 +00:00 committed by Gerrit Code Review
commit 93618a2f70

View File

@ -71,9 +71,11 @@ class TaskManager(threading.Thread):
def run(self):
last_ts = 0
while self._running:
while True:
task = self.queue.get()
if not task:
if not self._running:
break
continue
while True:
delta = time.time() - last_ts