Merge pull request #251 from python-telegram-bot/fix_run_async

release semaphore on exceptions
This commit is contained in:
Jannes Höke 2016-04-24 15:59:09 +02:00
commit 564baea8c3

View file

@ -61,10 +61,13 @@ def run_async(func):
""" """
A wrapper to run a thread in a thread pool A wrapper to run a thread in a thread pool
""" """
result = func(*pargs, **kwargs) try:
semaphore.release() result = func(*pargs, **kwargs)
with async_lock: finally:
async_threads.remove(current_thread()) semaphore.release()
with async_lock:
async_threads.remove(current_thread())
return result return result
@wraps(func) @wraps(func)