Add tests for RESTART.

python-processing-unit · python-processing-unit · commit bb0678878835 · 2026-04-20T00:09:38.000-04:00
diff --git a/tests/cases/failing/restart-arity-two.pre b/tests/cases/failing/restart-arity-two.pre
@@ -0,0 +1 @@
+RESTART(ASYNC{}, ASYNC{})
diff --git a/tests/cases/failing/restart-arity-zero.pre b/tests/cases/failing/restart-arity-zero.pre
@@ -0,0 +1 @@
+RESTART()
diff --git a/tests/cases/failing/restart-bool.pre b/tests/cases/failing/restart-bool.pre
@@ -0,0 +1 @@
+RESTART(TRUE)
diff --git a/tests/cases/failing/restart-flt.pre b/tests/cases/failing/restart-flt.pre
@@ -0,0 +1 @@
+RESTART(0d1.0)
diff --git a/tests/cases/failing/restart-func.pre b/tests/cases/failing/restart-func.pre
@@ -0,0 +1 @@
+RESTART(LAMBDA BOOL: (){})
diff --git a/tests/cases/failing/restart-int.pre b/tests/cases/failing/restart-int.pre
@@ -0,0 +1 @@
+RESTART(0d1)
diff --git a/tests/cases/failing/restart-map.pre b/tests/cases/failing/restart-map.pre
@@ -0,0 +1 @@
+RESTART(<>)
diff --git a/tests/cases/failing/restart-running.pre b/tests/cases/failing/restart-running.pre
@@ -0,0 +1,5 @@
+THR: worker = ASYNC{
+    FOR(i, 0d100000){}
+}
+
+RESTART(worker)
diff --git a/tests/cases/failing/restart-str.pre b/tests/cases/failing/restart-str.pre
@@ -0,0 +1 @@
+RESTART("thread")
diff --git a/tests/cases/failing/restart-tns.pre b/tests/cases/failing/restart-tns.pre
@@ -0,0 +1 @@
+RESTART([0d1])
diff --git a/tests/cases/passing/restart-basic.pre b/tests/cases/passing/restart-basic.pre
@@ -0,0 +1,20 @@
+BOOL: finished = FALSE
+
+THR: worker = ASYNC{
+    FOR(i, 0d2){}
+    finished = TRUE
+}
+
+! Wait for worker to finish
+AWAIT(worker)
+ASSERT(EQ(finished, TRUE))
+
+! Restart the finished thread
+THR: r = RESTART(worker)
+ASSERT(EQ(TYPE(r), "THR"))
+ASSERT(EQ(r, worker))
+ASSERT(BOOL(r))
+
+! After restart, the thread should run again and set finished
+AWAIT(r)
+ASSERT(EQ(finished, TRUE))
