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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
|
# .tlv file generated by https://github.com/akkartik/teliva
# You may edit it if you are careful; however, you may see cryptic errors if you
# violate Teliva's assumptions.
#
# .tlv files are representations of Teliva programs. Teliva programs consist of
# sequences of definitions. Each definition is a table of key/value pairs. Keys
# and values are both strings.
#
# Lines in .tlv files always follow exactly one of the following forms:
# - comment lines at the top of the file starting with '#' at column 0
# - beginnings of definitions starting with '- ' at column 0, followed by a
# key/value pair
# - key/value pairs consisting of ' ' at column 0, containing either a
# spaceless value on the same line, or a multi-line value
# - multiline values indented by more than 2 spaces, starting with a '>'
#
# If these constraints are violated, Teliva may unceremoniously crash. Please
# report bugs at http://akkartik.name/contact
- __teliva_timestamp: original
check:
>function check(x, msg)
> if x then
> Window:addch('.')
> else
> print('F - '..msg)
> print(' '..str(x)..' is false/nil')
> teliva_num_test_failures = teliva_num_test_failures + 1
> -- overlay first test failure on editors
> if teliva_first_failure == nil then
> teliva_first_failure = msg
> end
> end
>end
- __teliva_timestamp: original
check_eq:
>function check_eq(x, expected, msg)
> if eq(x, expected) then
> Window:addch('.')
> else
> print('F - '..msg)
> print(' expected '..str(expected)..' but got '..str(x))
> teliva_num_test_failures = teliva_num_test_failures + 1
> -- overlay first test failure on editors
> if teliva_first_failure == nil then
> teliva_first_failure = msg
> end
> end
>end
- __teliva_timestamp: original
eq:
>function eq(a, b)
> if type(a) ~= type(b) then return false end
> if type(a) == 'table' then
> if #a ~= #b then return false end
> for k, v in pairs(a) do
> if b[k] ~= v then
> return false
> end
> end
> for k, v in pairs(b) do
> if a[k] ~= v then
> return false
> end
> end
> return true
> end
> return a == b
>end
- __teliva_timestamp: original
str:
>-- smarter tostring
>-- slow; used only for debugging
>function str(x)
> if type(x) == 'table' then
> local result = ''
> result = result..#x..'{'
> for k, v in pairs(x) do
> result = result..str(k)..'='..str(v)..', '
> end
> result = result..'}'
> return result
> elseif type(x) == 'string' then
> return '"'..x..'"'
> end
> return tostring(x)
>end
- __teliva_timestamp: original
menu:
>-- To show app-specific hotkeys in the menu bar, add hotkey/command
>-- arrays of strings to the menu array.
>menu = {}
- __teliva_timestamp: original
Window:
>Window = curses.stdscr()
- __teliva_timestamp: original
main:
>function main()
> task.spawn(main_task)
> task.scheduler()
> Window:refresh()
> Window:getch()
>end
- __teliva_timestamp: original
main_task:
>function main_task()
> Window:clear()
> local c = task.Channel:new()
> task.spawn(counter, c)
> for i=1,10 do
> print(c:recv())
> end
>end
- __teliva_timestamp:
>Sat Feb 26 21:50:11 2022
__teliva_note:
>a simple counter
counter:
>function counter(c)
> local i = 2
> while true do
> c:send(i)
> i = i+1
> end
>end
- __teliva_timestamp:
>Sat Feb 26 21:54:53 2022
filter_task:
>function filter_task(p, cin, cout)
> while true do
> local i = cin:recv()
> if i%p ~= 0 then
> cout:send(i)
> end
> end
>end
- __teliva_timestamp:
>Sat Feb 26 21:55:46 2022
main_task:
>function main_task()
> local primes = task.Channel:new()
> task.spawn(sieve, primes)
> for i=1,10 do
> print(primes:recv())
> end
>end
- __teliva_timestamp:
>Sat Feb 26 21:59:37 2022
__teliva_note:
>filter out multiples of a single number
sieve:
>function sieve(ch)
> local iota = task.Channel:new()
> task.spawn(counter, iota)
> task.spawn(filter_task, 2, iota, ch)
>end
- __teliva_timestamp:
>Sat Feb 26 22:08:07 2022
__teliva_note:
>implement the complete sieve algorithm
sieve:
>-- Set up a Sieve of Eratosthenes (https://en.wikipedia.org/wiki/Sieve_of_Eratosthenes)
>-- for computing prime numbers by chaining tasks, one per prime.
>-- Each task is responsible for filtering out all multiples of its prime.
>function sieve(primes_ch)
> local c = task.Channel:new()
> task.spawn(counter, c)
> while true do
> local p, newc = c:recv(), task.Channel:new()
> primes_ch:send(p)
> task.spawn(filter_task, p, c, newc)
> c = newc
> end
>end
- __teliva_timestamp:
>Sat Feb 26 22:09:47 2022
__teliva_note:
>infinite primes
main_task:
>function main_task()
> local primes = task.Channel:new()
> task.spawn(sieve, primes)
> while true do
> Window:addstr(primes:recv())
> Window:addstr(' ')
> Window:refresh()
> end
>end
- __teliva_timestamp:
>Sat Feb 26 22:09:47 2022
__teliva_note:
>clear screen when it fills up; pause on keypress
>
>In Teliva getch() implicitly refreshes the screen.
main_task:
>function main_task()
> Window:nodelay(true)
> Window:clear()
> local primes = task.Channel:new()
> task.spawn(sieve, primes)
> local h, w = Window:getmaxyx()
> while true do
> Window:addstr(primes:recv())
> Window:addstr(' ')
> local c = Window:getch()
> if c then break end -- key pressed
> local y, x = Window:getyx()
> if y > h-1 then
> Window:clear()
> end
> end
> print('key pressed; done')
> Window:nodelay(false)
>end
- __teliva_timestamp:
>Sat Feb 26 22:27:25 2022
doc:blurb:
>Sieve of Eratosthenes
>https://en.wikipedia.org/wiki/Sieve_of_Eratosthenes
>
>A demonstration of tasks and channels, the primitives for (cooperative) concurrency in Teliva.
>
>We string together a cascade of tasks connected by channels. Every prime number gets a new task that prints the first incoming number, and then filters out multiples of it from the incoming channel.
>
>This approach has the advantage that we don't need to create an array of n numbers to compute primes less than n.
>
>However, we still need to create p tasks and p channels if there are p primes less than n. Probably not worth it, given tasks and channels are much larger than numbers. This is just a demo.
>
>The noticeable periodic pauses are perhaps due to garbage collection.
|