ThreadPool: issue _semaphore._start_notify() after maxsize change

8ac95135 · Denis Bilenko · f43db0d6 · 8ac95135
Commit 8ac95135 authored Jan 10, 2012 by Denis Bilenko
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 0 deletions

gevent/threadpool.py gevent/threadpool.py +2 -0

No files found.
--- a/gevent/threadpool.py
+++ b/gevent/threadpool.py
@@ -36,6 +36,8 @@ class ThreadPool(object):
        self._maxsize = maxsize
        self._remove_threads()
        self._add_threads()
+        # make sure all currently blocking spawn() start unlocking if maxsize increased
+        self._semaphore._start_notify()

    def _get_maxsize(self):
        return self._maxsize