]> git.ipfire.org Git - thirdparty/Python/cpython.git/commit
gh-107219: Fix concurrent.futures terminate_broken() (#109244)
authorVictor Stinner <vstinner@python.org>
Mon, 11 Sep 2023 08:11:31 +0000 (10:11 +0200)
committerGitHub <noreply@github.com>
Mon, 11 Sep 2023 08:11:31 +0000 (08:11 +0000)
commita9b1f84790e977fb09f75b148c4c4f5924a6ef99
tree836a2e8244e2bcafa81cddaeb88e8489f63231b0
parent3b2ecbc1275bd05534885cee9ac1389987238561
gh-107219: Fix concurrent.futures terminate_broken() (#109244)

Fix a race condition in concurrent.futures. When a process in the
process pool was terminated abruptly (while the future was running or
pending), close the connection write end. If the call queue is
blocked on sending bytes to a worker process, closing the connection
write end interrupts the send, so the queue can be closed.

Changes:

* _ExecutorManagerThread.terminate_broken() now closes
  call_queue._writer.
* multiprocessing PipeConnection.close() now interrupts
  WaitForMultipleObjects() in _send_bytes() by cancelling the
  overlapped operation.
Lib/concurrent/futures/process.py
Lib/multiprocessing/connection.py
Misc/NEWS.d/next/Library/2023-09-11-00-32-18.gh-issue-107219.3zqyFT.rst [new file with mode: 0644]