diff options
author | Gregory P. Smith <greg@krypto.org> | 2016-08-07 10:19:20 -0700 |
---|---|---|
committer | Gregory P. Smith <greg@krypto.org> | 2016-08-07 10:19:20 -0700 |
commit | 50abe877ee6f50ebd9cfe228d314220e071fa3c6 (patch) | |
tree | 9858ef0cc4b0b534eb18fc539d3ac62c256f3584 /Lib/test/test_concurrent_futures.py | |
parent | d0d24fd1ae05a2aea84165cf0aae98f75a5203c8 (diff) | |
download | cpython-git-50abe877ee6f50ebd9cfe228d314220e071fa3c6.tar.gz |
Issue #27664: Add to concurrent.futures.thread.ThreadPoolExecutor()
the ability to specify a thread name prefix.
Diffstat (limited to 'Lib/test/test_concurrent_futures.py')
-rw-r--r-- | Lib/test/test_concurrent_futures.py | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/Lib/test/test_concurrent_futures.py b/Lib/test/test_concurrent_futures.py index cdb93088a2..46b069c59d 100644 --- a/Lib/test/test_concurrent_futures.py +++ b/Lib/test/test_concurrent_futures.py @@ -154,6 +154,30 @@ class ThreadPoolShutdownTest(ThreadPoolMixin, ExecutorShutdownTest, unittest.Tes for t in threads: t.join() + def test_thread_names_assigned(self): + executor = futures.ThreadPoolExecutor( + max_workers=5, thread_name_prefix='SpecialPool') + executor.map(abs, range(-5, 5)) + threads = executor._threads + del executor + + for t in threads: + self.assertRegex(t.name, r'^SpecialPool_[0-4]$') + t.join() + + def test_thread_names_default(self): + executor = futures.ThreadPoolExecutor(max_workers=5) + executor.map(abs, range(-5, 5)) + threads = executor._threads + del executor + + for t in threads: + # We don't particularly care what the default name is, just that + # it has a default name implying that it is a ThreadPoolExecutor + # followed by what looks like a thread number. + self.assertRegex(t.name, r'^.*ThreadPoolExecutor.*_[0-4]$') + t.join() + class ProcessPoolShutdownTest(ProcessPoolMixin, ExecutorShutdownTest, unittest.TestCase): def _prime_executor(self): |