From ffc7ee63834b51ead589cc99183e4c0ca070079e Mon Sep 17 00:00:00 2001
From: Sam Gross <colesbury@gmail.com>
Date: Sat, 1 Mar 2025 11:58:04 -0500
Subject: [PATCH] Revert "gh-128364: Fix flaky `test_timeout` test (gh-130724)"

Change broke Android and iOS buildbots that do not have multiprocessing.

This reverts commit cfa0b1dc375e63cde28e61a47108c645b0e74834.
---
 Lib/test/test_concurrent_futures/test_wait.py | 6 ++----
 Lib/test/test_concurrent_futures/util.py      | 7 -------
 2 files changed, 2 insertions(+), 11 deletions(-)

diff --git a/Lib/test/test_concurrent_futures/test_wait.py b/Lib/test/test_concurrent_futures/test_wait.py
index 697285779510a9..108cf54bf79e6f 100644
--- a/Lib/test/test_concurrent_futures/test_wait.py
+++ b/Lib/test/test_concurrent_futures/test_wait.py
@@ -114,8 +114,9 @@ def test_all_completed(self):
 
     def test_timeout(self):
         short_timeout = 0.050
+        long_timeout = short_timeout * 10
 
-        future = self.executor.submit(self.event.wait)
+        future = self.executor.submit(time.sleep, long_timeout)
 
         finished, pending = futures.wait(
                 [CANCELLED_AND_NOTIFIED_FUTURE,
@@ -131,9 +132,6 @@ def test_timeout(self):
                          finished)
         self.assertEqual(set([future]), pending)
 
-        # Set the event to allow the future to complete
-        self.event.set()
-
 
 class ThreadPoolWaitTests(ThreadPoolMixin, WaitTests, BaseTestCase):
 
diff --git a/Lib/test/test_concurrent_futures/util.py b/Lib/test/test_concurrent_futures/util.py
index 4e9e4ef1daec03..44086217f9dbcb 100644
--- a/Lib/test/test_concurrent_futures/util.py
+++ b/Lib/test/test_concurrent_futures/util.py
@@ -1,6 +1,5 @@
 import multiprocessing
 import sys
-import threading
 import time
 import unittest
 from concurrent import futures
@@ -47,14 +46,11 @@ def setUp(self):
 
         self.t1 = time.monotonic()
         if hasattr(self, "ctx"):
-            self.manager = multiprocessing.Manager()
-            self.event = self.manager.Event()
             self.executor = self.executor_type(
                 max_workers=self.worker_count,
                 mp_context=self.get_context(),
                 **self.executor_kwargs)
         else:
-            self.event = threading.Event()
             self.executor = self.executor_type(
                 max_workers=self.worker_count,
                 **self.executor_kwargs)
@@ -62,9 +58,6 @@ def setUp(self):
     def tearDown(self):
         self.executor.shutdown(wait=True)
         self.executor = None
-        if hasattr(self, "ctx"):
-            self.manager.shutdown()
-            self.manager = None
 
         dt = time.monotonic() - self.t1
         if support.verbose: