From a851c7e6bbed4a0c4e718bff7669095a7572b31b Mon Sep 17 00:00:00 2001
From: martinko <gamato@users.sf.net>
Date: Wed, 27 Feb 2013 14:23:22 +0100
Subject: [PATCH] pgq.cascade.admin: amended threading

---
 python/pgq/cascade/admin.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py
index a8236816..ed44dad7 100644
--- a/python/pgq/cascade/admin.py
+++ b/python/pgq/cascade/admin.py
@@ -363,9 +363,10 @@ class CascadeAdmin(skytools.AdminScript):
         nodes = Queue.Queue()
 
         # launch workers and wait
-        n = min (members.qsize(), 1000)
+        n = max (min (members.qsize() >> 2, 100), 1)
         for i in range(n):
             t = threading.Thread (target = self._cmd_status_worker, args = (members, nodes))
+            t.daemon = True
             t.start()
         members.join()
 
-- 
2.39.5