Abstract Thread/Task wrapper for general use

Author: NoahStapp

test/asynchronous/utils_spec_runner.py

@@ -61,14 +61,11 @@
     PARENT = object
 
 
-class SpecRunnerTask(PARENT):
-    def __init__(self, name):
-        super().__init__()
+class ConcurrentRunner(PARENT):
+    def __init__(self, name, *args, **kwargs):
+        if _IS_SYNC:
+            super().__init__(*args, **kwargs)
         self.name = name
-        self.exc = None
-        self.daemon = True
-        self.cond = _async_create_condition(_async_create_lock())
-        self.ops = []
         self.stopped = False
         self.task = None
 
@@ -84,6 +81,15 @@ async def join(self, timeout: float | None = 0):  # type: ignore[override]
         def is_alive(self):
             return not self.stopped
 
+
+class SpecRunnerTask(ConcurrentRunner):
+    def __init__(self, name):
+        super().__init__(name)
+        self.exc = None
+        self.daemon = True
+        self.cond = _async_create_condition(_async_create_lock())
+        self.ops = []
+
     async def schedule(self, work):
         self.ops.append(work)
         async with self.cond:

test/utils_spec_runner.py

@@ -61,14 +61,11 @@
     PARENT = object
 
 
-class SpecRunnerThread(PARENT):
-    def __init__(self, name):
-        super().__init__()
+class ConcurrentRunner(PARENT):
+    def __init__(self, name, *args, **kwargs):
+        if _IS_SYNC:
+            super().__init__(*args, **kwargs)
         self.name = name
-        self.exc = None
-        self.daemon = True
-        self.cond = _create_condition(_create_lock())
-        self.ops = []
         self.stopped = False
         self.task = None
 
@@ -84,6 +81,15 @@ def join(self, timeout: float | None = 0):  # type: ignore[override]
         def is_alive(self):
             return not self.stopped
 
+
+class SpecRunnerThread(ConcurrentRunner):
+    def __init__(self, name):
+        super().__init__(name)
+        self.exc = None
+        self.daemon = True
+        self.cond = _create_condition(_create_lock())
+        self.ops = []
+
     def schedule(self, work):
         self.ops.append(work)
         with self.cond: