在前面的几篇中定时器其实我们已经应用过了,入口函数就是靠定时器驱动的,只不过他的定时为0.参见skynet lua业务逻辑的启动--skynet.start() .
在后面的服务与服务交互中,为了保证在A服务call B服时,B服务已经启动,我们特意在A服务call前执行了一个无意义的循环.这节中的定时器就可以解决这个问题,调用skynet.sleep(xxx)就可以让协程挂起.我们看看sleep的代码:
function skynet.sleep(ti)
local session = c.intcommand("TIMEOUT",ti) --①
assert(session)
local succ, ret = coroutine_yield("SLEEP", session) --②
sleep_session[coroutine.running()] = nil
if succ then
return
end
if ret == "BREAK" then
return "BREAK"
else
error(ret)
end
end
①处会调用c的timeout接口,前面讲过.由于ti不为0,那么他会在c中注册一个定时器事件,等定时器超时,他会push一个PTYPE_RESPONSE类型,包含session的消息.(c中怎么调度定时器另起一篇再介绍)
②处导致正在执行的协程挂起,这会让corutine.resume返回去执行suspend.
suspend()函数中'sleep'命令的处理只是关联了两个表,一个用co作key,session作value,另一个以session作key,co作value.他们的作用是,当收到定时器消息时能够快速找到关联的协程co,并恢复该协程co,这样经sleep挂起的协程就又恢复了.
注意skynet.sleep()参数是以100为单位,即100表示一秒.
skynet.sleep()应该很好理解,再来稍难点的.有这样一个需求:如何像linux c 一样创建两个线程,然后独自运行线程函数.skynet提供了skynet.fork(),一个例子如下:
skynet.start(function()
function myfork( val )
while true do
print('myfork ', val, ' !!!! ')
skynet.sleep(200)
end
end
local co1 = skynet.fork(myfork, 1)
local co2 = skynet.fork(myfork, 2)
end)
运行结果为:
可以看到两个'线程函数'交替的运行了,我们来分析一下:
function skynet.fork(func,...)
local args = { ... }
local co = co_create(function()
func(tunpack(args))
end)
table.insert(fork_queue, co)
return co
end
可以看到fork实际上是创建了一个协程函数,并插入到表里,那什么时候开始执行协程函数呢?
我们追溯fork_queue,发现他是在skynet.dispatch_message()被执行的:
function skynet.dispatch_message(...)
local succ, err = pcall(raw_dispatch_message,...)
while true do
local key,co = next(fork_queue) --表示获取表的第一个元素和key,t={12,a=34,5,c}都可以访问到
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
succ = false
err = tostring(fork_err)
else
err = tostring(err) .. "\n" .. tostring(fork_err)
end
end
end
assert(succ, tostring(err))
end
我们看到必须要等到skynet.raw_dispatch_message函数执行完成.
结合前面的几篇文章分析,必须等到skynet.raw_dispatch_message()里的suspend函数执行完毕.而suspend函数开始执行要等到coroutine.resume()返回.所以必须等到执行中的协程挂起,才有机会执行fork里的协程了.
要想执行中的协程被挂起,除了调用skynet.sleep()之外,当前消息回调函数执行完毕也会调用coroutine_yield "EXIT",参看前面讲解co_create()的部分.
需要注意的是,在lua里多个协程函数不可能像linux c多线程一样真正同时执行,同一时间只有一个协程函数在执行,只不过利用协程调度,可以做到同时执行的假象罢了.
所以当一个协程里执行死循环时,另一个协程时不可能有机会再执行的,这点千万要注意!!!
