Apr 30, 2025 · Apr 30, 2025 · Apr 30, 2025 · Apr 30, 2025 · Apr 30, 2025 · Apr 30, 2025
diff --git a/Lib/test/test_concurrent_futures/test_shutdown.py b/Lib/test/test_concurrent_futures/test_shutdown.py
        time.sleep(0.1 * n)
        return n

    def _run_test_issue_gh_132969(self, max_workers: int) -> int:
    def _run_test_issue_gh_132969(self, max_workers):
        # max_workers=2 will repro exception
        # max_workers=4 will repro exception and then hang

            # stop processing results upon first exception
            pass

        # Ensure that the executor cleans up after called
        # shutdown with wait=False
        executor_manager_thread = executor._executor_manager_thread
        executor.shutdown(wait=False)
        time.sleep(0.2)
        executor_manager_thread.join()
        return result

    def test_shutdown_gh_132969_case_1(self):
Original file line number	Diff line number	Diff line change
Expand Up		@@ -339,7 +339,7 @@ def _good_task_gh_132969(cls, n):
		time.sleep(0.1 * n)
		return n

ogbiggles marked this conversation as resolved. Show resolvedHide resolved
		def _run_test_issue_gh_132969(self, max_workers: int) -> int:
		def _run_test_issue_gh_132969(self, max_workers):
		# max_workers=2 will repro exception
		# max_workers=4 will repro exception and then hang

Expand All		@@ -366,7 +366,12 @@ def _run_test_issue_gh_132969(self, max_workers: int) -> int:
		# stop processing results upon first exception
		pass

		# Ensure that the executor cleans up after called
		# shutdown with wait=False
		executor_manager_thread = executor._executor_manager_thread
		executor.shutdown(wait=False)
		time.sleep(0.2)
		executor_manager_thread.join()
		return result

		def test_shutdown_gh_132969_case_1(self):
Expand Down