【性能调优】事件节流：同帧重复事件的合并

---事件总线：同帧同键事件合并
local Bus = { subs = {}, pending = {} }

function Bus.publish(key, payload)
    local subs = Bus.subs[key]
    if not subs then return end
    -- 同帧的同键事件：只保留最新载荷
    Bus.pending[key] = payload
end

setontimerex(94, 1)
function Bus.flush()
    for key, payload in pairs(Bus.pending) do
        for _, fn in ipairs(Bus.subs[key] or {}) do
            fn(payload)
        end
        Bus.pending[key] = nil
    end
end

---动作类事件的节流：窗口内限次
local Throttle = {}

function Bus.publishThrottled(key, payload, windowMs, cap)
    local now = os.clock()
    local t = Throttle[key]
    if not t then
        t = { windowStart = now, count = 0 }
        Throttle[key] = t
    end
    if now - t.windowStart > windowMs / 1000 then
        t.windowStart = now
        t.count = 0
    end
    t.count = t.count + 1
    if t.count > cap then return false end   -- 超出窗口容量丢弃
    Bus.publish(key, payload)
    return true
end

---聊天广播的节流：每秒最多 30 条
Bus.publishThrottled("chat_world", msg, 1000, 30)