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
|
local fixture = require "fixture"
local lanes = require "lanes".configure{on_state_create = fixture.on_state_create}
local fixture = require "fixture"
lanes.finally(fixture.throwing_finalizer)
-- this test is only for Lua 5.4+
local utils = lanes.require "_utils54"
local PRINT = utils.MAKE_PRINT()
local out_linda = lanes.linda()
------------------------------------------------------------------------------
-- TEST: to-be-closed variables are properly closed when the lane is collected
------------------------------------------------------------------------------
if true then
-- the generator
local coro_g = lanes.coro("*", utils.yielder_with_to_be_closed)
-- start the lane
local h = coro_g(out_linda)
-- join the lane. it should be done and give back the values resulting of the first yield point
local r, v1, v2 = h:join()
assert(r == true and v1 == "I yield!" and v2 == 1, "got " .. tostring(r) .. " " .. tostring(v1) .. " " .. tostring(v2))
assert(h.status == "done", "got " .. h.status)
-- force collection of the lane
h = nil
collectgarbage()
-- I want the to-be-closed variable of the coroutine linda to be properly closed
local s, r = out_linda:receive(0, "out")
assert(s == "out" and r == "Closed!", "coro got " .. tostring(s) .. " " .. tostring(r)) -- THIS TEST FAILS
end
---------------------------------------------------------------------------------------------------
-- TEST: if a to-be-closed handler takes longer than the join timeout, everything works as expected
---------------------------------------------------------------------------------------------------
if true then
-- the generator
local coro_g = lanes.coro("*", utils.yielder_with_to_be_closed)
-- start the lane. The to-be-closed handler will sleep for 1 second
local h = coro_g(out_linda, 1)
-- first join attempt should timeout
local r, v = h:join(0.6)
assert(r == nil and v == "timeout", "got " .. tostring(r) .. " " .. tostring(v))
assert(h.status == "running", "got " .. h.status)
-- join the lane again. it should be done and give back the values resulting of the first yield point
local r, v1, v2 = h:join(0.6)
assert(r == true and v1 == "I yield!" and v2 == 1, "got " .. tostring(r) .. " " .. tostring(v1) .. " " .. tostring(v2))
assert(h.status == "done", "got " .. h.status)
-- force collection of the lane
h = nil
collectgarbage()
-- I want the to-be-closed variable of the coroutine linda to be properly closed
local s, r = out_linda:receive(0, "out")
assert(s == "out" and r == "Closed!", "coro got " .. tostring(s) .. " " .. tostring(r)) -- THIS TEST FAILS
end
|
