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

recycle coroutine bugfix

Browse Source
This commit is contained in:
Cloud Wu
2018-06-07 17:27:21 +08:00
committed by 云风
parent b1ec1f4d18
commit 4b5fbab129
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
lualib/skynet.lua
View File

@@ -134,8 +134,6 @@ local function co_create(f)
skynet.address(session_coroutine_address[co]), skynet.address(session_coroutine_address[co]),
source.source, source.linedefined)) source.source, source.linedefined))
end end
f = nil
coroutine_pool[#coroutine_pool+1] = co
-- coroutine exit -- coroutine exit
local tag = session_coroutine_tracetag[co] local tag = session_coroutine_tracetag[co]
if tag then if tag then
@@ -148,12 +146,19 @@ local function co_create(f)
session_coroutine_id[co] = nil session_coroutine_id[co] = nil
end end
-- recycle co into pool
f = nil
coroutine_pool[#coroutine_pool+1] = co
-- recv new main function f
f = coroutine_yield "SUSPEND" f = coroutine_yield "SUSPEND"
f(coroutine_yield()) f(coroutine_yield())
end end
end) end)
else else
-- pass the main function f to coroutine, and restore running thread
local running = running_thread
coroutine_resume(co, f) coroutine_resume(co, f)
running_thread = running
end end
return co return co
end end