在前面的几篇中定时器其实我们已经应用过了,入口函数就是靠定时器驱动的,只不过他的定时为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
if ret == "BREAK" then
return "BREAK"
error(ret)
①处会调用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)
local co1 = skynet.fork(myfork, 1)
local co2 = skynet.fork(myfork, 2)
运行结果为:
可以看到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
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)
err = tostring(err) .. "\n" .. tostring(fork_err)
assert(succ, tostring(err))