【Lua实战】事件总线批量派发：事件分发的批量优化实现

local queue = {}
local function pushKill(actor, victim)
    local player = class(actor)
    table.insert(queue, { killer = player:GetName(), victim = victim })
end
local subs = {}
local function onFlush()
    if #queue == 0 then return end
    for _, fn in ipairs(subs) do
        fn(queue)
    end
    queue = {}
end

setontimerex(125, 1)
function ontimer125()
    if os.time() * 1000 % 500 < 50 then
        onFlush()
    end
end
local function subscribe(fn)
    table.insert(subs, fn)
end
subscribe(function(batch)
    for _, e in ipairs(batch) do
        countAchieve(e.killer)
    end
end)