openstack/oslo.messaging
Code Issues Proposed changes

Merge "support ability to set thread pool size per listener"

Browse Source
This commit is contained in:
Jenkins 2016-02-08 21:36:14 +00:00 committed by Gerrit Code Review
commit ea204a0f6d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
oslo_messaging/_executors/impl_pooledexecutor.py
View File

@ -104,9 +104,13 @@ class PooledExecutor(base.ExecutorBase):
if not was_submitted:
break
def start(self):
def start(self, override_pool_size=None):
if self._executor is None:
if override_pool_size is not None and int(override_pool_size) < 1:
raise ValueError('The thread pool size should be a positive '
'value.')
self._executor = self._executor_cls(
override_pool_size if override_pool_size else
self.conf.executor_thread_pool_size)
self._tombstone.clear()
if self._poller is None or not self._poller.is_alive():