mirror of
https://github.com/python/cpython.git
synced 2025-11-13 07:26:31 +00:00
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.
This commit is contained in:
parent
a15d155aad
commit
3bcf157c11
1 changed files with 3 additions and 0 deletions
|
|
@ -222,11 +222,14 @@ class ProcessPoolShutdownTest(ProcessPoolMixin, ExecutorShutdownTest, BaseTestCa
|
||||||
list(executor.map(abs, range(-5, 5)))
|
list(executor.map(abs, range(-5, 5)))
|
||||||
queue_management_thread = executor._queue_management_thread
|
queue_management_thread = executor._queue_management_thread
|
||||||
processes = executor._processes
|
processes = executor._processes
|
||||||
|
call_queue = executor._call_queue
|
||||||
del executor
|
del executor
|
||||||
|
|
||||||
queue_management_thread.join()
|
queue_management_thread.join()
|
||||||
for p in processes.values():
|
for p in processes.values():
|
||||||
p.join()
|
p.join()
|
||||||
|
call_queue.close()
|
||||||
|
call_queue.join_thread()
|
||||||
|
|
||||||
|
|
||||||
class WaitTests:
|
class WaitTests:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue