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

order fork, see #1000

Browse Source
This commit is contained in:
Cloud Wu
2019-04-28 09:53:52 +08:00
parent 04e2a36c4a
commit 4159600fbc
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lualib/skynet.lua
View File

@@ -6,6 +6,7 @@ local assert = assert
local pairs = pairs
local pcall = pcall
local table = table
local tremove = table.remove
local profile = require "skynet.profile"
@@ -70,7 +71,7 @@ local suspend
----- monitor exit
local function dispatch_error_queue()
local session = table.remove(error_queue,1)
local session = tremove(error_queue,1)
if session then
local co = session_id_coroutine[session]
session_id_coroutine[session] = nil
@@ -105,7 +106,7 @@ end
local coroutine_pool = setmetatable({}, { __mode = "kv" })
local function co_create(f)
local co = table.remove(coroutine_pool)
local co = tremove(coroutine_pool)
if co == nil then
co = coroutine_create(function(...)
f(...)
@@ -148,7 +149,7 @@ local function co_create(f)
end
local function dispatch_wakeup()
local token = table.remove(wakeup_queue,1)
local token = tremove(wakeup_queue,1)
if token then
local session = sleep_session[token]
if session then
@@ -597,11 +598,10 @@ end
function skynet.dispatch_message(...)
local succ, err = pcall(raw_dispatch_message,...)
while true do
local key,co = next(fork_queue)
local co = tremove(fork_queue,1)
if co == nil then
break
end
fork_queue[key] = nil
local fork_succ, fork_err = pcall(suspend,co,coroutine_resume(co))
if not fork_succ then
if succ then