openstack
/
futurist
Code Issues Proposed changes

Remove 'smart' idleness check 

This needs further improvement as it does not appear
to be working as expected so for now just revert it back
to the naive (and more expected) behavior for starting up
new workers (and adding them to the worker pool).

Change-Id: Ia9cc4e44c55ea39bc6270ed42b375ca495bf9ec1
This commit is contained in:
Joshua Harlow 2016-07-13 13:15:46 -07:00
parent 4edd53045b
commit 6d4e15a676
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
futurist/_futures.py
View File

@ -151,10 +151,10 @@ class ThreadPoolExecutor(_futures.Executor):
def _maybe_spin_up(self):
"""Spin up a worker if needed."""
# Do more advanced idle checks and/or reaping of very idle
# threads in the future....
if (not self._workers or
(len(self._workers) < self._max_workers and not
# Do more advanced idle checks in the future....
any(w.idle for w in self._workers))):
len(self._workers) < self._max_workers):
w = _thread.ThreadWorker.create_and_register(
self, self._work_queue)
# Always save it before we start (so that even if we fail