support process for scheduler

1 files changed, 15 insertions, 0 deletions

diff --git a/tests/modules/process/sched_process.lua b/tests/modules/process/sched_process.lua
new file mode 100644
index 000000000..c9b629b03
--- /dev/null
+++ b/tests/modules/process/sched_process.lua
@@ -0,0 +1,15 @@
+import("core.base.scheduler")
+
+function _session(id, program, ...)
+    local proc = process.openv(program, table.pack(...))
+    local ok, status = proc:wait(-1)
+    print("%s/%d: %d, status: %d", proc, id, ok, status)
+    proc:close()
+end
+
+function main(program, ...)
+    for i = 1, 10 do
+        scheduler.co_start(_session, i, program, ...)
+    end
+    scheduler.runloop()
+end