From 027ee83c6fd911779bea195746cb857faf8b63ce Mon Sep 17 00:00:00 2001 From: shortcutme Date: Fri, 13 Oct 2017 01:23:26 +0200 Subject: [PATCH] Wait 0.1s for new tasks before shut down worker --- src/Worker/Worker.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/Worker/Worker.py b/src/Worker/Worker.py index be04dca7..d0f1b661 100644 --- a/src/Worker/Worker.py +++ b/src/Worker/Worker.py @@ -28,9 +28,12 @@ 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 - self.manager.log.debug("%s: No task found, stopping" % self.key) - break + 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"]: task["time_started"] = time.time() # Task started now