Skip to content

Schedule

Jump to bottom
Bruce edited this page Sep 21, 2025 · 1 revision

sidebar_position: 5

服务调度

Lua协程

flowchart TD
    A([moon.async]) --> B[创建协程]
    B --> C[执行函数直到yield点]
    C --> D[阻塞等待moon.call,moon.sleep]
    C --> E[继续执行]
    D --> F[被唤醒]
    E --> G[任务完成]
    F --> G
    G --> H[协程结束]
Loading 
---创建一个新的协程并立即开始执行, 带有`async`标记的函数都需要在`moon.async`中调用。如果 fn 函数没有调用 coroutine.yield, 则会同步执行。
--- ```lua
--- local function foo(a, b)
---     print("start foo", a, b)
---     moon.sleep(1000)
---     print("end foo", a, b)
--- end
--- local function bar(a, b)
---     print("start bar", a, b)
---     moon.sleep(500)
---     print("end bar", a, b)
--- end
--- moon.async(foo, 1, 2)
--- moon.async(bar, 3, 4)
--- ```
---
---@param fn fun(...) @需要异步执行的函数
---@param ... any @可选参数，传递给 fn 函数
---@return thread @新创建的协程
moon.async(fn, ...)

定时器

创建协程风格的定时器moon.sleep 

    ---阻塞当前协程至少`mills`毫秒
    ---@async
    ---@param mills integer@ 毫秒
    ---@return boolean @ `moon.wakeup`唤醒的定时器返回`false`, 正常触发的定时器返回`true`
    moon.sleep(mills)

示例

    moon.async(function()
        print("coroutine timer start")
        moon.sleep(1000)
        print("coroutine timer tick 1 seconds")
        moon.sleep(1000)
        print("coroutine timer tick 1 seconds")
        moon.sleep(1000)
        print("coroutine timer tick 1 seconds")
        moon.sleep(1000)
        print("coroutine timer tick 1 seconds")
        moon.sleep(1000)
        print("coroutine timer tick 1 seconds")
        print("coroutine timer end")
    end)
    2023-06-16 20:37:24.824 | :01000001 | INFO  | coroutine timer start     (example_timer.lua:9)
    2023-06-16 20:37:25.830 | :01000001 | INFO  | coroutine timer tick 1 seconds    (example_timer.lua:11)
    2023-06-16 20:37:26.841 | :01000001 | INFO  | coroutine timer tick 1 seconds    (example_timer.lua:13)
    2023-06-16 20:37:27.850 | :01000001 | INFO  | coroutine timer tick 1 seconds    (example_timer.lua:15)
    2023-06-16 20:37:28.857 | :01000001 | INFO  | coroutine timer tick 1 seconds    (example_timer.lua:17)
    2023-06-16 20:37:29.869 | :01000001 | INFO  | coroutine timer tick 1 seconds    (example_timer.lua:19)
    2023-06-16 20:37:29.869 | :01000001 | INFO  | coroutine timer end       (example_timer.lua:20)

使用moon.sleep(0)让出协程执行权

moon.async创建的lua协程占用执行权后，其他的协程需要等待，可以使用moon.sleep(0)让出当前协程执行权

    ---模拟繁重的任务
    local function heavy_task(name)
        local i = 0
        print(name, "begin task")
        while (i < 200000000) do
            i = i + 1
            if i % 50000000 == 0 then
                moon.sleep(0)
                print(name, "task yield")
            end
        end
        print(name, "end task", i)
    end

    moon.async(heavy_task, "task1")
    moon.async(heavy_task, "task2")
    2023-06-16 20:30:02.440 | :01000001 | INFO  | task1     begin task      (example_timer.lua:35)
    2023-06-16 20:30:04.679 | :01000001 | INFO  | task2     begin task      (example_timer.lua:35)
    2023-06-16 20:30:06.910 | :01000001 | INFO  | task1     task yield      (example_timer.lua:40)
    2023-06-16 20:30:09.129 | :01000001 | INFO  | task2     task yield      (example_timer.lua:40)
    2023-06-16 20:30:11.375 | :01000001 | INFO  | task1     task yield      (example_timer.lua:40)
    2023-06-16 20:30:13.593 | :01000001 | INFO  | task2     task yield      (example_timer.lua:40)
    2023-06-16 20:30:15.822 | :01000001 | INFO  | task1     task yield      (example_timer.lua:40)
    2023-06-16 20:30:18.086 | :01000001 | INFO  | task2     task yield      (example_timer.lua:40)
    2023-06-16 20:30:20.349 | :01000001 | INFO  | task1     task yield      (example_timer.lua:40)
    2023-06-16 20:30:20.349 | :01000001 | INFO  | task1     end task        200000000       (example_timer.lua:43)
    2023-06-16 20:30:20.349 | :01000001 | INFO  | task2     task yield      (example_timer.lua:40)
    2023-06-16 20:30:20.349 | :01000001 | INFO  | task2     end task        200000000       (example_timer.lua:43)

使用moon.wakeup唤醒moon.sleep阻塞的协程

    local co = moon.async(function()
        print("wakeup", moon.sleep(10000))
    end)

    moon.async(function()
        print("normal", moon.sleep(1000))
        moon.wakeup(co)
    end)
    2023-06-16 20:36:44.494 | :01000001 | INFO  | normal    true    (example_timer.lua:28)
    2023-06-16 20:36:44.494 | :01000001 | INFO  | wakeup    false   (example_timer.lua:24)

创建回调方式的定时moon.timeout 

    ---创建一个定时器,等待的mills毫秒后触发回调函数。如果`mills<=0`则这个函数的行为退化成向消息队列post一条消息,对于需要延迟(delay)执行的操作非常有用。
    ---@param mills integer @等待的毫秒数
    ---@param fn fun() @调用的函数
    ---@return integer @ 返回timerid,可以使用`moon.remove_timer`删除定时器
    moon.timeout(mills, fn)

示例

    local timerid = moon.timeout(1000, function()
        print("hello world")
    end)

删除定时器moon.remove_timer 

    local timerid = moon.timeout(1000, function()
        error("must not print")
    end)
    moon.remove_timer(timerid)

获取时间

获取当前毫秒时间戳moon.now(),可能会有误差

    moon.async(function()
        print("start", moon.now())
        moon.sleep(1000)
        print("1 seconds later", moon.now())
        moon.sleep(2000)
        print("2 seconds later", moon.now())
        print("end", moon.now())
    end)
    2023-06-16 20:48:28.664 | :01000001 | INFO  | start     1686919708655   (example_timer.lua:51)
    2023-06-16 20:48:29.666 | :01000001 | INFO  | 1 seconds later   1686919709666   (example_timer.lua:53)
    2023-06-16 20:48:31.672 | :01000001 | INFO  | 2 seconds later   1686919711672   (example_timer.lua:55)
    2023-06-16 20:48:31.672 | :01000001 | INFO  | end       1686919711672   (example_timer.lua:56)

获取当前秒时间戳moon.time() 

    moon.async(function()
        print("start", moon.time())
        moon.sleep(1000)
        print("1 seconds later", moon.time())
        moon.sleep(2000)
        print("2 seconds later", moon.time())
        print("end", moon.time())
    end)
    2023-06-16 20:49:16.434 | :01000001 | INFO  | start     1686919756      (example_timer.lua:51)
    2023-06-16 20:49:17.432 | :01000001 | INFO  | 1 seconds later   1686919757      (example_timer.lua:53)
    2023-06-16 20:49:19.441 | :01000001 | INFO  | 2 seconds later   1686919759      (example_timer.lua:55)
    2023-06-16 20:49:19.441 | :01000001 | INFO  | end       1686919759      (example_timer.lua:56)

使用moon.clock()获取函数执行时间

    moon.async(function()
        local t1 = moon.clock()
        print("start", t1)
        moon.sleep(1235)
        local t2 = moon.clock()
        print("end", t2)
        print("cost", t2 - t1)
    end)
    2023-06-16 20:52:13.310 | :01000001 | INFO  | start     0.039369        (example_timer.lua:61)
    2023-06-16 20:52:14.543 | :01000001 | INFO  | end       1.2728892       (example_timer.lua:64)
    2023-06-16 20:52:14.543 | :01000001 | INFO  | cost      1.2335202       (example_timer.lua:65)

框架基础

进阶

Clone this wiki locally