31 lines
1.0 KiB
Lua
Executable File
31 lines
1.0 KiB
Lua
Executable File
module("AsyncWorkDispatcher", package.seeall)
|
||
|
||
local CallBackList = {}
|
||
|
||
-- @brief 添加异步工作
|
||
-- @param asyncWork 异步工作内容 => { 'function', arg1, arg2 ... }
|
||
-- @param callback 完成回调 格式： callback(paramPack,retParam...) => paramPack为传入参数包，retParam为异步工作返回值
|
||
-- @param paramPack 回调参数包
|
||
-- @note asyncWork.function 在异步线程中调用，且应函数应定义在 AsyncWorkerFunction.txt
|
||
function Add(asyncWork,callback,paramPack)
|
||
local cbid = System.addAsyncWorker(asyncWork)
|
||
if cbid ~= nil and cbid ~= 0 and callback ~= nil then
|
||
CallBackList[cbid] = {callback, paramPack}
|
||
end
|
||
end
|
||
|
||
--------------------------------------------------------------------
|
||
-- 提供给CPP的回调
|
||
--------------------------------------------------------------------
|
||
|
||
function OnWorkFinish(cbid, empty, ...)
|
||
if not cbid then return end
|
||
local callback = CallBackList[cbid]
|
||
if callback ~= nil then
|
||
func = callback[1]
|
||
paramPack = callback[2]
|
||
func(paramPack, ...)
|
||
CallBackList[cbid] = nil
|
||
end
|
||
end
|