diff options
| -rw-r--r-- | python/pgq/cascade/admin.py | 3 |
1 files changed, 2 insertions, 1 deletions
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() |