summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGregory P. Smith <greg@mad-scientist.com>2008-01-22 01:20:42 (GMT)
committerGregory P. Smith <greg@mad-scientist.com>2008-01-22 01:20:42 (GMT)
commit95cd5c0b72db09426f96c8e5716404da01048f93 (patch)
treee689b7c7d35b345d6038825cbad7fa136c4b59f9
parent64c5677de4e979d1496d8851dcc27078caa89d40 (diff)
downloadcpython-95cd5c0b72db09426f96c8e5716404da01048f93.zip
cpython-95cd5c0b72db09426f96c8e5716404da01048f93.tar.gz
cpython-95cd5c0b72db09426f96c8e5716404da01048f93.tar.bz2
- Fix Issue #1703448: A joined thread could show up in the
threading.enumerate() list after the join() for a brief period until it actually exited.
-rw-r--r--Lib/test/test_threading.py18
-rw-r--r--Lib/threading.py13
-rw-r--r--Misc/NEWS4
3 files changed, 30 insertions, 5 deletions
diff --git a/Lib/test/test_threading.py b/Lib/test/test_threading.py
index 9e26536..4f49d7f 100644
--- a/Lib/test/test_threading.py
+++ b/Lib/test/test_threading.py
@@ -236,6 +236,24 @@ class ThreadTests(unittest.TestCase):
"""])
self.assertEqual(rc, 42)
+ def test_enumerate_after_join(self):
+ # Try hard to trigger #1703448: a thread is still returned in
+ # threading.enumerate() after it has been join()ed.
+ enum = threading.enumerate
+ old_interval = sys.getcheckinterval()
+ sys.setcheckinterval(1)
+ try:
+ for i in xrange(1, 1000):
+ t = threading.Thread(target=lambda: None)
+ t.start()
+ t.join()
+ l = enum()
+ self.assertFalse(t in l,
+ "#1703448 triggered after %d trials: %s" % (i, l))
+ finally:
+ sys.setcheckinterval(old_interval)
+
+
class ThreadingExceptionTests(unittest.TestCase):
# A RuntimeError should be raised if Thread.start() is called
# multiple times.
diff --git a/Lib/threading.py b/Lib/threading.py
index 98d15b2..50cbb06 100644
--- a/Lib/threading.py
+++ b/Lib/threading.py
@@ -515,11 +515,14 @@ class Thread(_Verbose):
if __debug__:
self._note("%s.__bootstrap(): normal return", self)
finally:
- self.__stop()
- try:
- self.__delete()
- except:
- pass
+ with _active_limbo_lock:
+ self.__stop()
+ try:
+ # We don't call self.__delete() because it also
+ # grabs _active_limbo_lock.
+ del _active[_get_ident()]
+ except:
+ pass
def __stop(self):
with self.__block:
diff --git a/Misc/NEWS b/Misc/NEWS
index 2aabfbc..3b55d74 100644
--- a/Misc/NEWS
+++ b/Misc/NEWS
@@ -371,6 +371,10 @@ Core and builtins
- Issue #1537: Changed GeneratorExit's base class from Exception to
BaseException.
+- Fix Issue #1703448: A joined thread could show up in the
+ threading.enumerate() list after the join() for a brief period until
+ it actually exited.
+
Library
-------