[Python-checkins] bpo-31249: Fix test_concurrent_futures dangling thread (#3521)

Tue Sep 12 20:05:56 EDT 2017

https://github.com/python/cpython/commit/3bcf157c115ba3e48bce62ac8cb13c703475a113
commit: 3bcf157c115ba3e48bce62ac8cb13c703475a113
branch: master
author: Victor Stinner <victor.stinner at gmail.com>
committer: GitHub <noreply at github.com>
date: 2017年09月12日T17:05:53-07:00
summary:
bpo-31249: Fix test_concurrent_futures dangling thread (#3521)
ProcessPoolShutdownTest.test_del_shutdown() now closes the call queue
and joins its thread, to prevent leaking a dangling thread.
files:
M Lib/test/test_concurrent_futures.py

diff --git a/Lib/test/test_concurrent_futures.py b/Lib/test/test_concurrent_futures.py
index a888dcacc49..7bc733efb1e 100644
--- a/Lib/test/test_concurrent_futures.py
+++ b/Lib/test/test_concurrent_futures.py
@@ -222,11 +222,14 @@ def test_del_shutdown(self):
 list(executor.map(abs, range(-5, 5)))
 queue_management_thread = executor._queue_management_thread
 processes = executor._processes
+ call_queue = executor._call_queue
 del executor
 
 queue_management_thread.join()
 for p in processes.values():
 p.join()
+ call_queue.close()
+ call_queue.join_thread()
 
 
 class WaitTests:
