diff options
| author | Brian Quinlan <brian@sweetapp.com> | 2011-04-07 22:19:33 (GMT) |
|---|---|---|
| committer | Brian Quinlan <brian@sweetapp.com> | 2011-04-07 22:19:33 (GMT) |
| commit | f007876bd64def2829a242e0cf5adfd3ef25c4be (patch) | |
| tree | 1ec073f7cf806fa500a9146363e56686f90497aa /Lib/test | |
| parent | 0df80926c93ac71b032fffa215cf7b2f831d81b6 (diff) | |
| download | cpython-f007876bd64def2829a242e0cf5adfd3ef25c4be.zip cpython-f007876bd64def2829a242e0cf5adfd3ef25c4be.tar.gz cpython-f007876bd64def2829a242e0cf5adfd3ef25c4be.tar.bz2 | |
Issue #11777: Executor.map does not submit futures until iter.next() is called
Diffstat (limited to 'Lib/test')
| -rw-r--r-- | Lib/test/test_concurrent_futures.py | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/Lib/test/test_concurrent_futures.py b/Lib/test/test_concurrent_futures.py index 2662af7..ec84a66 100644 --- a/Lib/test/test_concurrent_futures.py +++ b/Lib/test/test_concurrent_futures.py @@ -369,7 +369,15 @@ class ExecutorTest(unittest.TestCase): class ThreadPoolExecutorTest(ThreadPoolMixin, ExecutorTest): - pass + def test_map_submits_without_iteration(self): + """Tests verifying issue 11777.""" + finished = [] + def record_finished(n): + finished.append(n) + + self.executor.map(record_finished, range(10)) + self.executor.shutdown(wait=True) + self.assertCountEqual(finished, range(10)) class ProcessPoolExecutorTest(ProcessPoolMixin, ExecutorTest): |