From 8363d53bd27c621cb342fea15736a3b11231f2a4 Mon Sep 17 00:00:00 2001 From: Bruce Hill Date: Sun, 18 Aug 2024 23:59:13 -0400 Subject: Update channel API to take a Where parameter --- test/threads.tm | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) (limited to 'test') diff --git a/test/threads.tm b/test/threads.tm index f7acd013..09ec7dc2 100644 --- a/test/threads.tm +++ b/test/threads.tm @@ -1,6 +1,24 @@ enum Job(Increment(x:Int), Decrement(x:Int)) func main(): + + do: + >> channel := |:Int| + >> channel:give(10) + >> channel:give(20) + >> channel:give(30) + >> channel:view() + = [10, 20, 30] + >> channel:peek() + = 10 + >> channel:peek(End) + = 30 + + >> channel:give(-10, Start) + >> channel:view() + = [-10, 10, 20, 30] + + jobs := |:Job; max_size=2| >> jobs:give(Increment(5)) >> jobs:peek() -- cgit v1.2.3