diff options
| author |   Thomas Moreau <thomas.moreau.2010@gmail.com> | 2018-03-12 18:18:41 +0100 |
|---|---|---|
| committer |   Andrew Svetlov <andrew.svetlov@gmail.com> | 2018-03-12 19:18:41 +0200 |
| commit | 095ee415cee41bf24c3a1108c23307e5baf168dd (patch) | |
| tree | ae5db621988c154d7a0481eabc053c6b3b1eef73 /Lib/concurrent | |
| parent | signal: add strsignal() (#6017) (diff) | |
| download | cpython-095ee415cee41bf24c3a1108c23307e5baf168dd.tar.gz cpython-095ee415cee41bf24c3a1108c23307e5baf168dd.tar.bz2 cpython-095ee415cee41bf24c3a1108c23307e5baf168dd.zip | |
bpo-33056 FIX leaking fd in concurrent.futures.ProcessPoolExecutor (#6084)
Diffstat (limited to 'Lib/concurrent')
| -rw-r--r-- | Lib/concurrent/futures/process.py | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py index aaa5151e017..63f22cfca32 100644 --- a/Lib/concurrent/futures/process.py +++ b/Lib/concurrent/futures/process.py @@ -78,11 +78,13 @@ _global_shutdown = False class _ThreadWakeup: - __slot__ = ["_state"] - def __init__(self): self._reader, self._writer = mp.Pipe(duplex=False) + def close(self): + self._writer.close() + self._reader.close() + def wakeup(self): self._writer.send_bytes(b"") @@ -654,6 +656,11 @@ class ProcessPoolExecutor(_base.Executor): self._call_queue = None self._result_queue = None self._processes = None + + if self._queue_management_thread_wakeup: + self._queue_management_thread_wakeup.close() + self._queue_management_thread_wakeup = None + shutdown.__doc__ = _base.Executor.shutdown.__doc__ atexit.register(_python_exit) |