summaryrefslogtreecommitdiff
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
parent2012269ac6d016c6dccd382f0fc14ea1ae0fd054 (diff)
add total to runjobs
-rw-r--r--tests/modules/scheduler/runjobs.lua10
-rw-r--r--xmake/modules/private/async/runjobs.lua2
2 files changed, 6 insertions, 6 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
diff --git a/xmake/modules/private/async/runjobs.lua b/xmake/modules/private/async/runjobs.lua
index 40f59f0bd..46a54e327 100644
--- a/xmake/modules/private/async/runjobs.lua
+++ b/xmake/modules/private/async/runjobs.lua
@@ -169,7 +169,7 @@ function main(name, jobs, opt)
try
{
function()
- jobfunc(i, job)
+ jobfunc(i, total, job)
end,
catch
{