forked from cloudwu/skynet
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathtestresponse.lua
44 lines (34 loc) · 831 Bytes
/
testresponse.lua
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
local skynet = require "skynet"
local mode = ...
if mode == "TICK" then
-- this service whould response the request every 1s.
local response_queue = {}
local function response()
while true do
skynet.sleep(100) -- sleep 1s
for k,v in ipairs(response_queue) do
v(true, skynet.now()) -- true means succ, false means error
response_queue[k] = nil
end
end
end
skynet.start(function()
skynet.fork(response)
skynet.dispatch("lua", function()
table.insert(response_queue, skynet.response())
end)
end)
else
local function request(tick, i)
print(i, "call", skynet.now())
print(i, "response", skynet.call(tick, "lua"))
print(i, "end", skynet.now())
end
skynet.start(function()
local tick = skynet.newservice(SERVICE_NAME, "TICK")
for i=1,5 do
skynet.fork(request, tick, i)
skynet.sleep(10)
end
end)
end