python
diff --git a/‎Lib/concurrent/futures/process.py‎
Lines changed: 5 additions & 1 deletion b/‎Lib/concurrent/futures/process.py‎
Lines changed: 5 additions & 1 deletion
diff --git a/‎Misc/NEWS.d/next/Library/2017-09-01-18-48-06.bpo-31326.TB05tV.rst‎
Lines changed: 3 additions & 0 deletions b/‎Misc/NEWS.d/next/Library/2017-09-01-18-48-06.bpo-31326.TB05tV.rst‎
Lines changed: 3 additions & 0 deletions
@@ -507,7 +507,11 @@ def shutdown(self, wait=True):
         # To reduce the risk of opening too many files, remove references to
         # objects that use file descriptors.
         self._queue_management_thread = None
-        self._call_queue = None
+        if self._call_queue is not None:
+            self._call_queue.close()
+            if wait:
+                self._call_queue.join_thread()
+            self._call_queue = None
         self._result_queue = None
         self._processes = None
     shutdown.__doc__ = _base.Executor.shutdown.__doc__
 
@@ -0,0 +1,3 @@
+concurrent.futures.ProcessPoolExecutor.shutdown() now explicitly closes the
+call queue. Moreover, shutdown(wait=True) now also join the call queue
+thread, to prevent leaking a dangling thread.
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+concurrent.futures.ProcessPoolExecutor.shutdown() now explicitly closes the`
	`2`	`+call queue. Moreover, shutdown(wait=True) now also join the call queue`
	`3`	`+thread, to prevent leaking a dangling thread.`