diff options
| author | Bruce Hill <bruce@bruce-hill.com> | 2025-03-31 02:11:03 -0400 |
|---|---|---|
| committer | Bruce Hill <bruce@bruce-hill.com> | 2025-03-31 02:11:03 -0400 |
| commit | 7a172be6213839a3d023ba21c3bafd7540a4bfe8 (patch) | |
| tree | 5646ba0e4c0690fe64711fb77658308541de695b /test/threads.tm | |
| parent | d3655740cc6a8e6c4788946af412065fb52f51dc (diff) | |
Remove threads and mutexed data from the language in favor of a
module-based approach
Diffstat (limited to 'test/threads.tm')
| -rw-r--r-- | test/threads.tm | 70 |
1 files changed, 0 insertions, 70 deletions
diff --git a/test/threads.tm b/test/threads.tm deleted file mode 100644 index adf7784a..00000000 --- a/test/threads.tm +++ /dev/null @@ -1,70 +0,0 @@ -enum Job(Increment(x:Int), Decrement(x:Int)) - -func main(): - do: - >> nums := mutexed [10, 20, 30] - holding nums: - >> nums[] - = [10, 20, 30] - nums:insert(40) - - holding nums: - >> nums[] - = [10, 20, 30, 40] - - - jobs := mutexed [Job.Increment(5)] - - results := mutexed [:Int] - - >> thread := Thread.new(func(): - !! In another thread! - repeat: - job := holding jobs: (jobs:pop(1) or stop) - when job is Increment(x): - holding results: results:insert(x + 1) - is Decrement(x): - holding results: results:insert(x - 1) - ) - - holding jobs: - jobs:insert(Decrement(100)) - jobs:insert(Decrement(200)) - jobs:insert(Decrement(300)) - jobs:insert(Decrement(400)) - jobs:insert(Decrement(500)) - jobs:insert(Decrement(600)) - jobs:insert(Increment(1000)) - - dequeue_result := func(): - result := none:Int - repeat: - result = (holding results: results:pop(1)) - stop if result - sleep(0.00001) - return result! - - >> dequeue_result() - = 6 - >> dequeue_result() - = 99 - - >> dequeue_result() - = 199 - >> dequeue_result() - = 299 - >> dequeue_result() - = 399 - >> dequeue_result() - = 499 - >> dequeue_result() - = 599 - - >> dequeue_result() - = 1001 - - !! Canceling... - >> thread:cancel() - !! Joining... - >> thread:join() - !! Done! |
