summaryrefslogtreecommitdiff
path: root/tests/modules
diff options
context:
space:
mode:
authorruki <[email protected]>2020-03-06 23:05:53 +0800
committerruki <[email protected]>2020-03-06 12:35:18 +0800
commit0152eb6ba443829ebd967e34b17354cb32e9678c (patch)
treeb737001c78207e3f4daa88a9ac6a4c16800d1967 /tests/modules
parent2012269ac6d016c6dccd382f0fc14ea1ae0fd054 (diff)
add total to runjobs
Diffstat (limited to 'tests/modules')
-rw-r--r--tests/modules/scheduler/runjobs.lua10
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/modules/scheduler/runjobs.lua b/tests/modules/scheduler/runjobs.lua
index e8e901a36..0ef0712b7 100644
--- a/tests/modules/scheduler/runjobs.lua
+++ b/tests/modules/scheduler/runjobs.lua
@@ -1,12 +1,12 @@
import("core.base.scheduler")
import("private.async.runjobs")
-function _jobfunc(index)
- print("%s: run job (%d)", scheduler.co_running(), index)
+function _jobfunc(index, total)
+ print("%s: run job (%d/%d)", scheduler.co_running(), index, total)
local dt = os.mclock()
os.sleep(1000)
dt = os.mclock() - dt
- print("%s: run job (%d) end, dt: %d ms", scheduler.co_running(), index, dt)
+ print("%s: run job (%d/%d) end, dt: %d ms", scheduler.co_running(), index, total, dt)
end
function main()
@@ -23,8 +23,8 @@ function main()
local jobs = {}
for i = 1, 3 do
for j = 1, 50 do
- table.insert(jobs, {priority = i, run = function (idx, job)
- _jobfunc(idx)
+ table.insert(jobs, {priority = i, run = function (idx, total, job)
+ _jobfunc(idx, total)
end})
end
end