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

Merge branch '3.1' of github.com:celery/celery into 3.1

Ask Solem преди 11 години
родител
ревизия
fc1701a992
променени са 1 файла, в които са добавени 10 реда и са изтрити 0 реда
  1. 10 0
      celery/concurrency/eventlet.py

+ 10 - 0
celery/concurrency/eventlet.py

@@ -143,6 +143,16 @@ class TaskPool(base.BasePool):
                         callback, accept_callback,
                         self.getpid)
 
+    def grow(self, n=1):
+        limit = self.limit + n
+        self._pool.resize(limit)
+        self.limit = limit
+
+    def shrink(self, n=1):
+        limit = self.limit - n
+        self._pool.resize(limit)
+        self.limit = limit
+
     def _get_info(self):
         return {
             'max-concurrency': self.limit,