Victor Stinner a9b1f84790 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.		2023-09-11 08:11:31 +00:00
..
__init__.py	bpo-46522: fix concurrent.futures and io AttributeError messages (GH-30887)	2022-02-23 02:25:00 +02:00
_base.py	gh-95166: cancel map waited on future on timeout (GH-95169)	2022-07-28 11:20:10 +02:00
process.py	gh-107219: Fix concurrent.futures terminate_broken() (#109244)	2023-09-11 08:11:31 +00:00
thread.py	gh-102024: Reduced _idle_semaphore.release calls (#102025)	2023-05-25 22:48:40 -07:00