impl private.async.runjobs

1 files changed, 14 insertions, 1 deletions

diff --git a/tests/modules/scheduler/test.lua b/tests/modules/scheduler/test.lua
index de62e47ed..853957567 100644
--- a/tests/modules/scheduler/test.lua
+++ b/tests/modules/scheduler/test.lua
@@ -1,6 +1,6 @@
 import("core.base.scheduler")
 
-function test_runjobs(t)
+function test_group(t)
 
     local count = 0
     local task = function (a)
@@ -46,3 +46,16 @@ function test_yield(t)
     scheduler.co_group_wait("test")
     t:are_equal(count, 10)
 end
+
+function test_runjobs(t)
+    import("private.async.runjobs")
+
+    local total = 100
+    local comax = 6
+    local count = 0
+    runjobs("test", function (index)
+        t:require(index >= 1 and index <= total)
+        count = count + 1
+    end, total, comax)
+    t:are_equal(count, total)
+end