mirror of
https://github.com/python/cpython.git
synced 2025-11-03 03:22:27 +00:00
Issue #19299: fix refleak test failures in test_asyncio
This commit is contained in:
parent
34d33a595b
commit
4ca7355901
3 changed files with 10 additions and 0 deletions
|
|
@ -185,6 +185,14 @@ class BaseEventLoop(events.AbstractEventLoop):
|
||||||
"""
|
"""
|
||||||
self.call_soon(_raise_stop_error)
|
self.call_soon(_raise_stop_error)
|
||||||
|
|
||||||
|
def close(self):
|
||||||
|
self._ready.clear()
|
||||||
|
self._scheduled.clear()
|
||||||
|
executor = self._default_executor
|
||||||
|
if executor is not None:
|
||||||
|
self._default_executor = None
|
||||||
|
executor.shutdown(wait=False)
|
||||||
|
|
||||||
def is_running(self):
|
def is_running(self):
|
||||||
"""Returns running status of event loop."""
|
"""Returns running status of event loop."""
|
||||||
return self._running
|
return self._running
|
||||||
|
|
|
||||||
|
|
@ -276,6 +276,7 @@ class BaseProactorEventLoop(base_events.BaseEventLoop):
|
||||||
self._proactor.close()
|
self._proactor.close()
|
||||||
self._proactor = None
|
self._proactor = None
|
||||||
self._selector = None
|
self._selector = None
|
||||||
|
super().close()
|
||||||
|
|
||||||
def sock_recv(self, sock, n):
|
def sock_recv(self, sock, n):
|
||||||
return self._proactor.recv(sock, n)
|
return self._proactor.recv(sock, n)
|
||||||
|
|
|
||||||
|
|
@ -56,6 +56,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
|
||||||
self._close_self_pipe()
|
self._close_self_pipe()
|
||||||
self._selector.close()
|
self._selector.close()
|
||||||
self._selector = None
|
self._selector = None
|
||||||
|
super().close()
|
||||||
|
|
||||||
def _socketpair(self):
|
def _socketpair(self):
|
||||||
raise NotImplementedError
|
raise NotImplementedError
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue