summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGregory P. Smith <greg@mad-scientist.com>2010-02-28 18:36:09 (GMT)
committerGregory P. Smith <greg@mad-scientist.com>2010-02-28 18:36:09 (GMT)
commit613c7a549abefd1f7806b61589667de683d76858 (patch)
tree1a7678d4b102a5dbc66e5822b49c568584e771be
parentb36e63a5ee7b1b8063b59f2be74703471ae45e1d (diff)
downloadcpython-613c7a549abefd1f7806b61589667de683d76858.zip
cpython-613c7a549abefd1f7806b61589667de683d76858.tar.gz
cpython-613c7a549abefd1f7806b61589667de683d76858.tar.bz2
Issue #7481: When a threading.Thread failed to start it would leave the
instance stuck in initial state and present in threading.enumerate().
-rw-r--r--Lib/test/test_threading.py19
-rw-r--r--Lib/threading.py7
-rw-r--r--Misc/NEWS3
3 files changed, 28 insertions, 1 deletions
diff --git a/Lib/test/test_threading.py b/Lib/test/test_threading.py
index 5daf822..defa9ee 100644
--- a/Lib/test/test_threading.py
+++ b/Lib/test/test_threading.py
@@ -249,6 +249,25 @@ class ThreadTests(BaseTestCase):
t.join()
# else the thread is still running, and we have no way to kill it
+ def test_limbo_cleanup(self):
+ # Issue 7481: Failure to start thread should cleanup the limbo map.
+ def fail_new_thread(*args):
+ raise thread.error()
+ _start_new_thread = threading._start_new_thread
+ threading._start_new_thread = fail_new_thread
+ try:
+ t = threading.Thread(target=lambda: None)
+ try:
+ t.start()
+ assert False
+ except thread.error:
+ self.assertFalse(
+ t in threading._limbo,
+ "Failed to cleanup _limbo map on failure of Thread.start()."
+ )
+ finally:
+ threading._start_new_thread = _start_new_thread
+
def test_finalize_runnning_thread(self):
# Issue 1402: the PyGILState_Ensure / _Release functions may be called
# very late on python exit: on deallocation of a running thread for
diff --git a/Lib/threading.py b/Lib/threading.py
index 5674010..c6fb2da 100644
--- a/Lib/threading.py
+++ b/Lib/threading.py
@@ -469,7 +469,12 @@ class Thread(_Verbose):
self._note("%s.start(): starting thread", self)
with _active_limbo_lock:
_limbo[self] = self
- _start_new_thread(self.__bootstrap, ())
+ try:
+ _start_new_thread(self.__bootstrap, ())
+ except Exception:
+ with _active_limbo_lock:
+ del _limbo[self]
+ raise
self.__started.wait()
def run(self):
diff --git a/Misc/NEWS b/Misc/NEWS
index f206f03..5b61109 100644
--- a/Misc/NEWS
+++ b/Misc/NEWS
@@ -72,6 +72,9 @@ Library
- Issue #7427: improve the representation of httplib.BadStatusLine exceptions.
+- Issue #7481: When a threading.Thread failed to start it would leave the
+ instance stuck in initial state and present in threading.enumerate().
+
Extension Modules
-----------------