From 1a275013d1ecc2e3778d64fda86174b2f13d6969 Mon Sep 17 00:00:00 2001 From: Victor Stinner Date: Mon, 27 Apr 2020 20:53:37 +0200 Subject: [PATCH] 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 | 2 ++ .../next/Library/2020-04-27-20-27-39.bpo-30966.Xmtlqu.rst | 2 ++ 2 files changed, 4 insertions(+) create mode 100644 Misc/NEWS.d/next/Library/2020-04-27-20-27-39.bpo-30966.Xmtlqu.rst diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py index 36355ae8756..8e9b69a8f08 100644 --- a/Lib/concurrent/futures/process.py +++ b/Lib/concurrent/futures/process.py @@ -728,6 +728,8 @@ class ProcessPoolExecutor(_base.Executor): # 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 diff --git a/Misc/NEWS.d/next/Library/2020-04-27-20-27-39.bpo-30966.Xmtlqu.rst b/Misc/NEWS.d/next/Library/2020-04-27-20-27-39.bpo-30966.Xmtlqu.rst new file mode 100644 index 00000000000..85b7934ba66 --- /dev/null +++ b/Misc/NEWS.d/next/Library/2020-04-27-20-27-39.bpo-30966.Xmtlqu.rst @@ -0,0 +1,2 @@ +``Process.shutdown(wait=True)`` of :mod:`concurrent.futures` now closes +explicitly the result queue.