diff options
Diffstat (limited to 'eventlet/tpool.py')
| -rw-r--r-- | eventlet/tpool.py | 10 |
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() |
