diff options
| -rw-r--r-- | tests/modules/scheduler/runjobs.lua | 10 | ||||
| -rw-r--r-- | xmake/modules/private/async/runjobs.lua | 2 |
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 { |