Rewrite a thread shim for compatibility with python 3.14+

Author: KirillovProj

hstest/common/process_utils.py

@@ -3,7 +3,7 @@
 import threading
 import weakref
 from concurrent.futures import ThreadPoolExecutor
-from concurrent.futures.thread import _worker
+from concurrent.futures.thread import _worker, _threads_queues
 from typing import TYPE_CHECKING
 
 if TYPE_CHECKING:
@@ -29,17 +29,26 @@ def weakref_cb(_, q=self._work_queue) -> None:
         if num_threads < self._max_workers:
             thread_name = "%s_%d" % (self._thread_name_prefix or self, num_threads)
 
-            args = (
-                weakref.ref(self, weakref_cb),
-                self._work_queue,
-                self._initializer,
-                self._initargs,
-            )
-
-            t = threading.Thread(name=thread_name, target=_worker, args=args, group=self.group)
+            # Python 3.14+ refactored initializer/initargs into WorkerContext
+            if hasattr(self, "_create_worker_context"):
+                args = (
+                    weakref.ref(self, weakref_cb),
+                    self._create_worker_context(),
+                    self._work_queue,
+                )
+            else:
+                args = (
+                    weakref.ref(self, weakref_cb),
+                    self._work_queue,
+                    self._initializer,
+                    self._initargs,
+                )
+
+            t = threading.Thread(name=thread_name, target=_worker, args=args)
             t.daemon = True
             t.start()
             self._threads.add(t)
+            _threads_queues[t] = self._work_queue
 
 
 def is_port_in_use(port):