Add channels and threads

2 files changed, 33 insertions, 1 deletions

diff --git a/test/text.tm b/test/text.tm
index 27c8c08a..4051a16f 100644
--- a/test/text.tm
+++ b/test/text.tm
@@ -1,6 +1,6 @@
 func main():
 	>> str := "Hello Amélie!"
-	| Testing strings like {str}
+	//! Testing strings like {str}
 
 	>> str:upper()
 	= "HELLO AMÉLIE!"
diff --git a/test/threads.tm b/test/threads.tm
new file mode 100644
index 00000000..33685103
--- /dev/null
+++ b/test/threads.tm
@@ -0,0 +1,32 @@
+enum Job(Increment(x:Int), Decrement(x:Int))
+
+func main():
+    jobs := |:Job|
+    results := |:Int|
+    >> thread := Thread.new(func():
+        //! In another thread!
+        while yes:
+            when jobs:pop() is Increment(x):
+                >> results:push(x+1)
+            is Decrement(x):
+                >> results:push(x-1)
+    )
+
+    >> jobs:push(Increment(5))
+    >> jobs:push(Decrement(100))
+
+    >> results:pop()
+    = 6
+
+    >> jobs:push(Increment(1000))
+    >> results:pop()
+    = 99
+
+    >> results:pop()
+    = 1001
+
+    //! Canceling...
+    >> thread:cancel()
+    //! Joining...
+    >> thread:join()
+    //! Done!