blob: 3329e9d5ca342f82523e7a46d12ba71568aafcb0 (
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
50
51
52
53
54
55
|
local lanes = require "lanes".configure{on_state_create = require "fixture".on_state_create}
-- launch lanes that cooperate properly with cancellation request
local lane1 = function()
lane_threadname("lane1")
-- loop breaks on soft cancellation request
repeat
lanes.sleep(0)
until cancel_test(true)
print "lane1 cancelled"
end
local lane2 = function(linda_)
lane_threadname("lane2")
-- loop breaks on lane/linda cancellation
repeat
local k, v = linda_:receive('k')
until v == lanes.cancel_error
print "lane2 cancelled"
end
local lane3 = function()
lane_threadname("lane3")
-- this one cooperates too, because of the hook cancellation modes that Lanes will be using
local fixture = require "fixture"
repeat until fixture.give_me_back(false)
end
-- the generators
local g1 = lanes.gen("*", { name = 'auto' }, lane1)
local g2 = lanes.gen("*", { name = 'auto' }, lane2)
local g3 = lanes.gen("*", { name = 'auto' }, lane3)
-- launch lanes
local h1 = g1()
local linda = lanes.linda()
local h2 = g2(linda)
local h3 = g3()
lanes.sleep(0.1)
local is_running = function(lane_h)
local status = lane_h.status
return status == "running" or status == "waiting"
end
-- wait until they are all started
repeat until is_running(h1) and is_running(h2) and is_running(h3)
-- let the script terminate, Lanes should not crash at shutdown
|
