skynet.coroutine.status may return blocked

This commit is contained in:
Cloud Wu
2015-12-17 17:11:54 +08:00
parent 872491e968
commit 4a80a75fd6
2 changed files with 34 additions and 7 deletions

View File

@@ -80,6 +80,19 @@ end
end -- end of skynetco.resume end -- end of skynetco.resume
function skynetco.status(co)
local status = coroutine.status(co)
if status == "suspended" then
if skynet_coroutines[co] == false then
return "blocked"
else
return "suspended"
end
else
return status
end
end
function skynetco.yield(...) function skynetco.yield(...)
return coroutine_yield("USER", ...) return coroutine_yield("USER", ...)
end end

View File

@@ -2,23 +2,37 @@ local skynet = require "skynet"
-- You should use skynet.coroutine instead of origin coroutine in skynet -- You should use skynet.coroutine instead of origin coroutine in skynet
local coroutine = require "skynet.coroutine" local coroutine = require "skynet.coroutine"
local function status(co)
repeat
local status = coroutine.status(co)
print("STATUS", status)
skynet.sleep(100)
until status == "suspended"
repeat
local ok, n = assert(coroutine.resume(co))
print("status thread", n)
until not n
skynet.exit()
end
local function test(n) local function test(n)
print ("begin", coroutine.isskynetcoroutine()) local co = coroutine.running()
print ("begin", coroutine.isskynetcoroutine(co))
skynet.fork(status, co)
for i=1,n do for i=1,n do
skynet.sleep(100) skynet.sleep(100)
coroutine.yield(i) coroutine.yield(i)
end end
print "end" print "end"
return false
end end
skynet.start(function() skynet.start(function()
print("Is the main thead a skynet coroutine ?", coroutine.isskynetcoroutine(coroutine.running())) -- always false print("Is the main thead a skynet coroutine ?", coroutine.isskynetcoroutine()) -- always false
print(coroutine.resume(coroutine.running())) -- always return false print(coroutine.resume(coroutine.running())) -- always return false
local f = coroutine.wrap(test) local f = coroutine.wrap(test)
repeat for i=1,3 do
local n = f(5) local n = f(5)
print(n) print("main thread",n)
until not n end
skynet.exit()
end) end)