diff options
| author | Victor Stinner <vstinner@python.org> | 2020-04-27 18:53:37 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-04-27 18:53:37 (GMT) |
| commit | 1a275013d1ecc2e3778d64fda86174b2f13d6969 (patch) | |
| tree | 62fc2324c90a7d7417172487bd781794917a2555 | |
| parent | b94dbd7ac34dc0c79512656eb17f6f07e09fca7a (diff) | |
| download | cpython-1a275013d1ecc2e3778d64fda86174b2f13d6969.zip cpython-1a275013d1ecc2e3778d64fda86174b2f13d6969.tar.gz cpython-1a275013d1ecc2e3778d64fda86174b2f13d6969.tar.bz2 | |
bpo-30966: concurrent.futures.Process.shutdown() closes queue (GH-19738)
Process.shutdown(wait=True) of concurrent.futures now closes
explicitly the result queue.
| -rw-r--r-- | Lib/concurrent/futures/process.py | 2 | ||||
| -rw-r--r-- | Misc/NEWS.d/next/Library/2020-04-27-20-27-39.bpo-30966.Xmtlqu.rst | 2 |
2 files changed, 4 insertions, 0 deletions
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 @@ 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 0000000..85b7934 --- /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. |