From c62f0cb3b1f6f9ca4ce463b1c99b0543bdfa38d6 Mon Sep 17 00:00:00 2001 From: Suren Nihalani Date: Tue, 7 Nov 2017 09:35:23 -0800 Subject: bpo-31620: have asyncio/queues not leak memory when you've exceptions during waiting (#3813) --- Lib/asyncio/queues.py | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'Lib/asyncio/queues.py') diff --git a/Lib/asyncio/queues.py b/Lib/asyncio/queues.py index 2d38972c0d..1c66d67b04 100644 --- a/Lib/asyncio/queues.py +++ b/Lib/asyncio/queues.py @@ -167,6 +167,12 @@ class Queue: yield from getter except: getter.cancel() # Just in case getter is not done yet. + + try: + self._getters.remove(getter) + except ValueError: + pass + if not self.empty() and not getter.cancelled(): # We were woken up by put_nowait(), but can't take # the call. Wake up the next in line. -- cgit v1.2.1