Skip to content

Commit 1a27501

Browse files
authored
bpo-30966: concurrent.futures.Process.shutdown() closes queue (GH-19738)
Process.shutdown(wait=True) of concurrent.futures now closes explicitly the result queue.
1 parent b94dbd7 commit 1a27501

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

‎Lib/concurrent/futures/process.py‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -728,6 +728,8 @@ def shutdown(self, wait=True, *, cancel_futures=False):
728728
# objects that use file descriptors.
729729
self._executor_manager_thread = None
730730
self._call_queue = None
731+
if self._result_queue is not None and wait:
732+
self._result_queue.close()
731733
self._result_queue = None
732734
self._processes = None
733735

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
``Process.shutdown(wait=True)`` of :mod:`concurrent.futures` now closes
2+
explicitly the result queue.

0 commit comments

Comments
 (0)