add jobpool

1 files changed, 10 insertions, 3 deletions

diff --git a/tests/modules/scheduler/runjobs.lua b/tests/modules/scheduler/runjobs.lua
index 0ef0712b7..489e221ee 100644
--- a/tests/modules/scheduler/runjobs.lua
+++ b/tests/modules/scheduler/runjobs.lua
@@ -1,4 +1,5 @@
 import("core.base.scheduler")
+import("private.async.jobpool")
 import("private.async.runjobs")
 
 function _jobfunc(index, total)
@@ -20,12 +21,18 @@ function main()
 
     -- test jobs
     print("==================================== test jobs ====================================")
-    local jobs = {}
+    local jobs = jobpool.new()
+    local root = jobs:addjob("job/root", function (idx, total, job)
+        _jobfunc(idx, total)
+    end)
     for i = 1, 3 do
+        local job = jobs:addjob("job/" .. i, function (idx, total, job)
+            _jobfunc(idx, total)
+        end, root)
         for j = 1, 50 do
-            table.insert(jobs, {priority = i, run = function (idx, total, job)
+            jobs:addjob("job/" .. i .. "/" .. j, function (idx, total, job)
                 _jobfunc(idx, total)
-            end})
+            end, job)
         end
     end
     t = os.mclock()