add back run_concurrently

Author: kumaraditya303

Lib/test/test_free_threading/test_bisect.py

@@ -1,6 +1,7 @@
 import unittest
 from test.support import import_helper, threading_helper
 import random
+from threading import Thread, Barrier
 
 py_bisect = import_helper.import_fresh_module('bisect', blocked=['_bisect'])
 c_bisect = import_helper.import_fresh_module('bisect', fresh=['_bisect'])
@@ -18,7 +19,7 @@ def insert(data):
                 insert_method(data, x)
 
         data = list(range(OBJECT_COUNT))
-        threading_helper.run_concurrently(
+        self.run_concurrently(
             worker_func=insert, args=(data,), nthreads=NTHREADS
         )
         if False:
@@ -41,6 +42,28 @@ def is_sorted_ascending(lst):
         """
         return all(lst[i - 1] <= lst[i] for i in range(1, len(lst)))
 
+    def run_concurrently(self, worker_func, args, nthreads):
+        """
+        Run the worker function concurrently in multiple threads.
+        """
+        barrier = Barrier(nthreads)
+
+        def wrapper_func(*args):
+            # Wait for all threads to reach this point before proceeding.
+            barrier.wait()
+            worker_func(*args)
+
+        with threading_helper.catch_threading_exception() as cm:
+            workers = (
+                Thread(target=wrapper_func, args=args)
+                for _ in range(nthreads)
+            )
+            with threading_helper.start_threads(workers):
+                pass
+
+            # Worker threads should not raise any exceptions
+            self.assertIsNone(cm.exc_value)
+
 
 @threading_helper.requires_working_threading()
 class TestPyBisect(unittest.TestCase, TestBase):