Adds grow/shrink methods to eventlet TaskPool

dongfanliang · May 29, 2014 · 1c60653 · 1c60653
1 parent 8d4354a
commit 1c60653
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/celery/concurrency/eventlet.py b/celery/concurrency/eventlet.py
@@ -131,6 +131,16 @@ def on_apply(self, target, args=None, kwargs=None, callback=None,
                         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,