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
|
local print = print
local lanes = require "lanes".configure{ with_timers = false, allocator="protected"}
local SLEEP = function(...)
local k, v = lanes.sleep(...)
assert(k == nil and v == "timeout")
end
local linda = lanes.linda()
local body = function( id_)
set_finalizer( function( err, stk)
if err == lanes.cancel_error then
-- lane cancellation is performed by throwing a special userdata as error
print( "after cancel")
elseif err then
-- no special error: true error
print( " error: "..tostring(err))
else
-- no error: we just got finalized
print( "[" .. id_ .. "] done")
end
end)
print( "[" .. id_ .. "] waiting for signal")
-- wait for the semaphore to be available
local _, cost = linda:receive( "lock")
-- starting to work
print( "[" .. id_ .. "] doing some allocations")
for i = 1, cost * (1 + id_ * 0.1) do
local t = { "some", "table", "with", "a", "few", "fields"}
end
linda:send( "key", "done")
end
-- start threads
local COUNT = 4
local gen = lanes.gen( "*", body)
for i = 1, COUNT do
gen( i)
end
-- wait a bit
print "waiting a bit ..."
SLEEP(2)
-- tell lanes to start running
print "GO!"
for i = 1, COUNT do
linda:send( "lock", 300000)
end
-- wait for completion
print "wait for completion"
linda:receive( linda.batched, "key", COUNT)
print "waiting a bit more ..."
SLEEP(1)
print "SUCCESS"
|
