Wait 0.1s for new tasks before shut down worker

2017-10-13 01:23:26 +02:00 · 2017-10-13 01:23:26 +02:00 · 027ee83c6f
commit 027ee83c6f
parent 60af54a17e
1 changed files with 6 additions and 3 deletions
--- a/src/Worker/Worker.py
+++ b/src/Worker/Worker.py
@ -28,7 +28,10 @@ class Worker(object):
        while self.running:
            # Try to pickup free file download task
            task = self.manager.getTask(self.peer)
-            if not task:  # Die, no more task
+            if not task:  # No more task
+                time.sleep(0.1)  # Wait a bit for new tasks
+                task = self.manager.getTask(self.peer)
+                if not task:  # Still no task, stop it
                    self.manager.log.debug("%s: No task found, stopping" % self.key)
                    break
            if not task["time_started"]: