lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 03:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

return results, see pr #403

Browse Source
This commit is contained in:
Cloud Wu
2015-12-04 10:47:30 +08:00
parent 1431f55d28
commit 3a2766dd0e
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
lualib/skynet/queue.lua
View File

@@ -8,6 +8,19 @@ function skynet.queue()
local current_thread
local ref = 0
local thread_queue = {}
local function xpcall_ret(ok, ...)
ref = ref - 1
if ref == 0 then
current_thread = table.remove(thread_queue,1)
if current_thread then
skynet.wakeup(current_thread)
end
end
assert(ok, (...))
return ...
end
return function(f, ...)
local thread = coroutine.running()
if current_thread and current_thread ~= thread then
@@ -18,15 +31,7 @@ function skynet.queue()
current_thread = thread
ref = ref + 1
local ok, err = xpcall(f, traceback, ...)
ref = ref - 1
if ref == 0 then
current_thread = table.remove(thread_queue,1)
if current_thread then
skynet.wakeup(current_thread)
end
end
assert(ok,err)
return xpcall_ret(xpcall(f, traceback, ...))
end
end