summaryrefslogtreecommitdiff
path: root/eventlet/tpool.py
diff options
context:
space:
mode:
Diffstat (limited to 'eventlet/tpool.py')
-rw-r--r--eventlet/tpool.py10
1 files changed, 10 insertions, 0 deletions
diff --git a/eventlet/tpool.py b/eventlet/tpool.py
index e7f0db1..8d73814 100644
--- a/eventlet/tpool.py
+++ b/eventlet/tpool.py
@@ -292,6 +292,16 @@ def killall():
for thr in _threads:
thr.join()
del _threads[:]
+
+ # return any remaining results
+ while not _rspq.empty():
+ try:
+ (e, rv) = _rspq.get(block=False)
+ e.send(rv)
+ e = rv = None
+ except Empty:
+ pass
+
if _coro is not None:
greenthread.kill(_coro)
_rsock.close()