blob: 95cfbb5b763b1af6823ea3c7a5f7a0969f55e210 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
enum Job(Increment(x:Int), Decrement(x:Int))
func main():
jobs := |:Job; max_size=2|
results := |:Int; max_size|
>> thread := Thread.new(func():
//! In another thread!
while yes:
>> got := jobs:pop()
when got is Increment(x):
>> results:push(x+1)
is Decrement(x):
>> results:push(x-1)
)
>> jobs:push(Increment(5))
>> jobs:push(Decrement(100))
>> jobs:push(Decrement(100))
>> jobs:push(Decrement(100))
>> jobs:push(Decrement(100))
>> jobs:push(Decrement(100))
>> jobs:push(Decrement(100))
>> results:pop()
= 6
>> jobs:push(Increment(1000))
>> results:pop()
= 99
>> results:pop()
= 99
>> results:pop()
= 99
>> results:pop()
= 99
>> results:pop()
= 99
>> results:pop()
= 99
>> results:pop()
= 1001
//! Canceling...
>> thread:cancel()
//! Joining...
>> thread:join()
//! Done!
|
