Преглед на файлове

Mediator: Don't sleep between blocking queue.get()'s

Ask Solem преди 14 години
родител
ревизия
89502dbd05
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      celery/worker/controllers.py

+ 1 - 1
celery/worker/controllers.py

@@ -89,7 +89,7 @@ class Mediator(BackgroundThread):
             # This blocks until there's a message in the queue.
             task = self.ready_queue.get(timeout=1)
         except QueueEmpty:
-            time.sleep(0.2)
+            pass
         else:
             if task.revoked():
                 return