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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
local timer = require 'timer'
---@class await
local m = {}
m.type = 'await'
m.coTracker = setmetatable({}, { __mode = 'k' })
m.coPriority = setmetatable({}, { __mode = 'k' })
m.delayQueue = {}
m.delayQueueIndex = 1
--- 设置错误处理器
---@param errHandle function {comment = '当有错误发生时，会以错误堆栈为参数调用该函数'}
function m.setErrorHandle(errHandle)
m.errorHandle = errHandle
end
function m.checkResult(co, ...)
local suc, err = ...
if not suc and m.errorHandle then
m.errorHandle(debug.traceback(co, err))
end
return ...
end
--- 创建一个任务
function m.create(callback, ...)
local co = coroutine.create(callback)
m.coTracker[co] = true
return m.checkResult(co, coroutine.resume(co, ...))
end
--- 休眠一段时间
---@param time number
function m.sleep(time, getVersion)
if not coroutine.isyieldable() then
if m.errorHandle then
m.errorHandle(debug.traceback('Cannot yield'))
end
return
end
local version = getVersion and getVersion()
local co = coroutine.running()
timer.wait(time, function ()
if version == (getVersion and getVersion()) then
return m.checkResult(co, coroutine.resume(co))
else
coroutine.close(co)
end
end)
return coroutine.yield(getVersion)
end
--- 等待直到唤醒
---@param callback function
function m.wait(callback, ...)
if not coroutine.isyieldable() then
return
end
local co = coroutine.running()
callback(function (...)
return m.checkResult(co, coroutine.resume(co, ...))
end)
return coroutine.yield(...)
end
--- 延迟
function m.delay(getVersion)
if not coroutine.isyieldable() then
return
end
local co = coroutine.running()
-- TODO
if m.coPriority[co] then
return
end
local version = getVersion and getVersion()
m.delayQueue[#m.delayQueue+1] = function ()
if version == (getVersion and getVersion()) then
return m.checkResult(co, coroutine.resume(co))
else
coroutine.close(co)
end
end
return coroutine.yield()
end
local function getCo(waker)
local co
for i = 1, 100 do
local n, v = debug.getupvalue(waker, i)
if not n then
return nil
end
if n == 'co' then
co = v
break
end
end
return co
end
--- 步进
function m.step()
local waker = m.delayQueue[m.delayQueueIndex]
if waker then
m.delayQueue[m.delayQueueIndex] = false
m.delayQueueIndex = m.delayQueueIndex + 1
local clock = os.clock()
waker()
local passed = os.clock() - clock
if passed > 0.1 then
log.debug(('Await step takes [%.3f] sec.'):format(passed))
end
return true
else
m.delayQueue = {}
m.delayQueueIndex = 1
return false
end
end
function m.setPriority(n)
m.coPriority[coroutine.running()] = n
end
return m
|
