bpo-31620: have asyncio/queues not leak memory when you've exceptions during waiting (#3813)

1 files changed, 6 insertions, 0 deletions

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.