commit 1a275013d1ecc2e3778d64fda86174b2f13d6969
author Victor Stinner <vstinner@python.org> Mon Apr 27 20:53:37 2020 +0200
committer GitHub <noreply@github.com> Mon Apr 27 20:53:37 2020 +0200
tree 62fc2324c90a7d7417172487bd781794917a2555
parent b94dbd7ac34dc0c79512656eb17f6f07e09fca7a

bpo-30966: concurrent.futures.Process.shutdown() closes queue (GH-19738)

Process.shutdown(wait=True) of concurrent.futures now closes
explicitly the result queue.

Lib/concurrent/futures/process.py

diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py
index 36355ae..8e9b69a 100644
--- a/Lib/concurrent/futures/process.py
+++ b/Lib/concurrent/futures/process.py
@@ -728,6 +728,8 @@
         # objects that use file descriptors.
         self._executor_manager_thread = None
         self._call_queue = None
+        if self._result_queue is not None and wait:
+            self._result_queue.close()
         self._result_queue = None
         self._processes = None