diff options
author | Antoine Pitrou <solipsis@pitrou.net> | 2012-04-19 21:55:01 (GMT) |
---|---|---|
committer | Antoine Pitrou <solipsis@pitrou.net> | 2012-04-19 21:55:01 (GMT) |
commit | 8e6e0fdb7fee3796df8b578c1311b5e46005f2d9 (patch) | |
tree | e1f800a5e8c4747cbe643209d54574ab8314b54b /Lib | |
parent | 10ac77d2d886c0921b21253b768fca8bc9b3c0dd (diff) | |
download | cpython-8e6e0fdb7fee3796df8b578c1311b5e46005f2d9.zip cpython-8e6e0fdb7fee3796df8b578c1311b5e46005f2d9.tar.gz cpython-8e6e0fdb7fee3796df8b578c1311b5e46005f2d9.tar.bz2 |
Issue #14308: Fix an exception when a "dummy" thread is in the threading module's active list after a fork().
Diffstat (limited to 'Lib')
-rw-r--r-- | Lib/test/test_threading.py | 29 | ||||
-rw-r--r-- | Lib/threading.py | 3 |
2 files changed, 32 insertions, 0 deletions
diff --git a/Lib/test/test_threading.py b/Lib/test/test_threading.py index dfc0ddf..00f73a7 100644 --- a/Lib/test/test_threading.py +++ b/Lib/test/test_threading.py @@ -2,6 +2,8 @@ import test.support from test.support import verbose, strip_python_stderr, import_module +from test.script_helper import assert_python_ok + import random import re import sys @@ -407,6 +409,33 @@ class ThreadTests(BaseTestCase): t.daemon = True self.assertTrue('daemon' in repr(t)) + @unittest.skipUnless(hasattr(os, 'fork'), 'test needs fork()') + def test_dummy_thread_after_fork(self): + # Issue #14308: a dummy thread in the active list doesn't mess up + # the after-fork mechanism. + code = """if 1: + import _thread, threading, os, time + + def background_thread(evt): + # Creates and registers the _DummyThread instance + threading.current_thread() + evt.set() + time.sleep(10) + + evt = threading.Event() + _thread.start_new_thread(background_thread, (evt,)) + evt.wait() + assert threading.active_count() == 2, threading.active_count() + if os.fork() == 0: + assert threading.active_count() == 1, threading.active_count() + os._exit(0) + else: + os.wait() + """ + _, out, err = assert_python_ok("-c", code) + self.assertEqual(out, b'') + self.assertEqual(err, b'') + class ThreadJoinOnShutdown(BaseTestCase): diff --git a/Lib/threading.py b/Lib/threading.py index 69b7763..58ffa7e 100644 --- a/Lib/threading.py +++ b/Lib/threading.py @@ -1007,6 +1007,9 @@ class _DummyThread(Thread): def _set_daemon(self): return True + def _stop(self): + pass + def join(self, timeout=None): assert False, "cannot join a dummy thread" |