skynet 定时器sleep与fork

在前面的几篇中定时器其实我们已经应用过了,入口函数就是靠定时器驱动的,只不过他的定时为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))