【高级技巧】协程管道实现生产者消费者：战报分帧落库

local function makePipeline(reports)
    local co = coroutine.create(function()
        for i = 1, #reports do
            coroutine.yield(reports[i])
        end
    end)
    return co
end
local pump = { co = nil, perFrame = 200, done = 0 }
local function pumpStep(p, reports)
    if p.co == nil then
        p.co = makePipeline(reports)
    end
    for _ = 1, p.perFrame do
        local ok, row = coroutine.resume(p.co)
        if not ok or row == nil then
            p.co = nil
            sendmsg(nil, 1, "战报落库完成，共 " .. p.done .. " 条。")
            p.done = 0
            return
        end
        p.done = p.done + 1
    end
end

local reports = {}
for i = 1, 10000 do
    reports[i] = "沙巴克战报" .. i
end