[issue14119] Ability to adjust queue size in Executors
Brian Quinlan
report at bugs.python.org
Sat Jan 11 01:43:38 CET 2014
Brian Quinlan added the comment:
Can't you accomplish what you want using add_done_callback?
e.g.
# Pseudocode
class MyExecutor(ThreadPoolExecutor):
def __init__(self):
self._count = 0
def _decrement(self):
with self._some_lock:
self._count -= 1
def submit(self, fn, *args, **kwargs):
f = super(self).submit(fn, *args, **kwargs)
with self._some_lock:
self._count += 1
f.add_done_callback(self._decrement)
@property
def num_pending_futures(self):
return self._count
----------
_______________________________________
Python tracker <report at bugs.python.org>
<http://bugs.python.org/issue14119>
_______________________________________
More information about the Python-bugs-list
mailing list