[lua]異步串行流程*協程
阿新 • • 發佈:2017-06-23
inf col agent urn pri nproc sum context bin
local function param_pack( params, callback ) local host = params[1] local service = table.remove(params, 2) table.insert(params, callback) return host, service, params end local function asyncall( ... ) local co, main = coroutine.running() if main then print(‘Please use .call(...) in .run(func) context‘) return end local function callback( ... ) local params = {co, ... } return coroutine.resume(unpack(params)) end local host, service local params = {...} if type(params[#params]) == ‘function‘ then host, service, params = table.remove(params)(params, callback)else host, service, params = param_pack(params, callback) end if type(host[service]) == ‘function‘ then return coroutine.yield(host[service](unpack(params))) else print(‘service:‘..service..‘ not implement at ‘..tostring(host)) end end local function runProcess( func, ... )local co = coroutine.create(func) local params = {co, ...} return coroutine.resume(unpack(params)) end local target = { call = asyncall, run = runProcess } return target --[[ -- example local Plugin = plugin.AgentManager:getUserPlugin() target.run(function ( ... ) local code, msg, info = target.call(Plugin, ‘queryThirdInfo‘, ‘weixin‘) if code == AsyncQueryStatus.kSuccess then dump(info) else print(msg) end code, msg = target.call(Plugin, ‘queryThirdAccountBindState‘, ‘weixin‘) end) --]]
[lua]異步串行流程*協程