Reference GH issue 94777.

python · Jul 10, 2023 · 2794188 · 2794188
1 parent 11c9c80
commit 2794188
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py
@@ -500,6 +500,7 @@ def terminate_broken(self, cause):
             p.terminate()
 
         # Prevent queue writing to a pipe which is no longer read.
+        # https://github.com/python/cpython/issues/94777
         self.call_queue._reader.close()
 
         # clean up resources

diff --git a/Lib/test/test_concurrent_futures.py b/Lib/test/test_concurrent_futures.py
@@ -1377,6 +1377,10 @@ def test_shutdown_deadlock_pickle(self):
         executor_manager.join()
 
     def test_crash_big_data(self):
+        # Test that there is a clean exception instad of a deadlock when a
+        # child process crashes while some data is being written into the
+        # queue.
+        # https://github.com/python/cpython/issues/94777
         self.executor.shutdown(wait=True)
         data = "a" * support.PIPE_MAX_SIZE
         with self.executor_type(max_workers=2,