diff options
author | Gregory P. Smith <greg@mad-scientist.com> | 2008-01-22 01:20:42 (GMT) |
---|---|---|
committer | Gregory P. Smith <greg@mad-scientist.com> | 2008-01-22 01:20:42 (GMT) |
commit | 95cd5c0b72db09426f96c8e5716404da01048f93 (patch) | |
tree | e689b7c7d35b345d6038825cbad7fa136c4b59f9 | |
parent | 64c5677de4e979d1496d8851dcc27078caa89d40 (diff) | |
download | cpython-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.py | 18 | ||||
-rw-r--r-- | Lib/threading.py | 13 | ||||
-rw-r--r-- | Misc/NEWS | 4 |
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: @@ -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 ------- |