summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVictor Stinner <vstinner@redhat.com>2019-08-19 22:37:17 (GMT)
committerGitHub <noreply@github.com>2019-08-19 22:37:17 (GMT)
commitd3dcc92778807ae8f7ebe85178f36a29711cd478 (patch)
tree9f416500ba67997ae72cda0594f5bcc62ac303b9
parentcf9360e524acafdce99a8a1e48947fd7da06f3d4 (diff)
downloadcpython-d3dcc92778807ae8f7ebe85178f36a29711cd478.zip
cpython-d3dcc92778807ae8f7ebe85178f36a29711cd478.tar.gz
cpython-d3dcc92778807ae8f7ebe85178f36a29711cd478.tar.bz2
bpo-37788: Fix a reference leak if a thread is not joined (GH-15228)
Add threading.Thread.__del__() method to ensure that the thread state lock is removed from the _shutdown_locks list when a thread completes.
-rw-r--r--Lib/test/test_threading.py8
-rw-r--r--Lib/threading.py10
-rw-r--r--Misc/NEWS.d/next/Library/2019-08-12-17-21-10.bpo-37788.F0tR05.rst1
3 files changed, 19 insertions, 0 deletions
diff --git a/Lib/test/test_threading.py b/Lib/test/test_threading.py
index 7c16974..5e90627 100644
--- a/Lib/test/test_threading.py
+++ b/Lib/test/test_threading.py
@@ -761,6 +761,14 @@ class ThreadTests(BaseTestCase):
# Daemon threads must never add it to _shutdown_locks.
self.assertNotIn(tstate_lock, threading._shutdown_locks)
+ def test_leak_without_join(self):
+ # bpo-37788: Test that a thread which is not joined explicitly
+ # does not leak. Test written for reference leak checks.
+ def noop(): pass
+ with support.wait_threads_exit():
+ threading.Thread(target=noop).start()
+ # Thread.join() is not called
+
class ThreadJoinOnShutdown(BaseTestCase):
diff --git a/Lib/threading.py b/Lib/threading.py
index 32a3d7c..67e1c4f 100644
--- a/Lib/threading.py
+++ b/Lib/threading.py
@@ -806,6 +806,16 @@ class Thread:
# For debugging and _after_fork()
_dangling.add(self)
+ def __del__(self):
+ if not self._initialized:
+ return
+ lock = self._tstate_lock
+ if lock is not None and not self.daemon:
+ # ensure that self._tstate_lock is not in _shutdown_locks
+ # if join() was not called explicitly
+ with _shutdown_locks_lock:
+ _shutdown_locks.discard(lock)
+
def _reset_internal_locks(self, is_alive):
# private! Called by _after_fork() to reset our internal locks as
# they may be in an invalid state leading to a deadlock or crash.
diff --git a/Misc/NEWS.d/next/Library/2019-08-12-17-21-10.bpo-37788.F0tR05.rst b/Misc/NEWS.d/next/Library/2019-08-12-17-21-10.bpo-37788.F0tR05.rst
new file mode 100644
index 0000000..d9b1e82
--- /dev/null
+++ b/Misc/NEWS.d/next/Library/2019-08-12-17-21-10.bpo-37788.F0tR05.rst
@@ -0,0 +1 @@
+Fix a reference leak if a thread is not joined.