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
|
--
-- KEEPER.LUA
--
-- Test program for Lua Lanes
--
local lanes = require "lanes".configure{ with_timers = false, nb_keepers = 1, keepers_gc_threshold = 500}
do
print "Linda names test:"
local unnamedLinda = lanes.linda()
local unnamedLinda2 = lanes.linda("")
local veeeerrrryyyylooongNamedLinda= lanes.linda( "veeeerrrryyyylooongNamedLinda", 1)
print(unnamedLinda, unnamedLinda2, veeeerrrryyyylooongNamedLinda)
print "GC deadlock test start"
-- store a linda in another linda (-> in a keeper)
unnamedLinda:set("here", lanes.linda("temporary linda"))
-- repeatedly add and remove stuff in the linda so that a GC happens during the keeper operation
for i = 1, 1000 do
for j = 1, 1000 do -- send 1000 tables
unnamedLinda:send("here", {"a", "table", "with", "some", "stuff"})
end
unnamedLinda:set("here") -- clear everything
end
end
print "collecting garbage"
collectgarbage()
print "GC deadlock test done"
local print_id = 0
local PRINT = function(...)
print_id = print_id + 1
print("main", print_id .. ".", ...)
end
local function keeper(linda)
local mt= {
__index= function( _, key )
return linda:get( key )
end,
__newindex= function( _, key, val )
linda:set( key, val )
end
}
return setmetatable( {}, mt )
end
--
local lindaA= lanes.linda( "A", 1)
local A= keeper( lindaA )
local lindaB= lanes.linda( "B", 2)
local B= keeper( lindaB )
local lindaC= lanes.linda( "C", 3)
local C= keeper( lindaC )
print("Created", lindaA, lindaB, lindaC)
A.some= 1
PRINT("A.some == " .. A.some )
assert( A.some==1 )
B.some= "hoo"
PRINT("B.some == " .. B.some )
assert( B.some=="hoo" )
assert( A.some==1 )
assert( C.some==nil )
function lane()
local print_id = 0
local PRINT = function(...)
print_id = print_id + 1
print("lane", print_id .. ".", ...)
end
local a= keeper(lindaA)
PRINT("a.some == " .. a.some )
assert( a.some==1 )
a.some= 2
assert( a.some==2 )
PRINT("a.some == " .. a.some )
local c = keeper(lindaC)
assert( c.some==nil )
PRINT("c.some == " .. tostring(c.some))
c.some= 3
assert( c.some==3 )
PRINT("c.some == " .. c.some)
end
PRINT("lane started")
local h= lanes.gen( "io", lane )()
PRINT("lane joined:", h:join())
PRINT("A.some = " .. A.some )
assert( A.some==2 )
PRINT("C.some = " .. C.some )
assert( C.some==3 )
lindaC:set("some")
assert( C.some==nil )
|
