skynet：fork

skynet 是多线程框架，此外在 skynet 中，每个服务对应一个 lua 虚拟机，一个虚拟机上可以跑多个协程，但同一时刻只能有一个协程，每条消息处理由协程来完成。

在 skynet 中，线程创建方式：

skynet.fork(func,…)

一、测试

main.lua

local skynet = require "skynet"skynet.start(function()function myfork( val )while true doprint('myfork ', val, ' !!!! ')skynet.sleep(200)endendlocal co1 = skynet.fork(myfork, 1)local co2 = skynet.fork(myfork, 2)end)

测试结果：

可以看到两个线程函数交替运行。

二、skynet.fork 原理

skynet.lua

function skynet.fork(func,...)local n = select("#", ...)--获取参数个数local coif n == 0 thenco = co_create(func)elselocal args = { ... }    --table.unpack(table, start, end)：返回 table 中 [start, end] 区间的元素，start 默认为1，end 默认为最后一个元素的位置        co = co_create(function() func(table.unpack(args,1,n)) end)--创建一个协程,相当于创建一个lua虚拟机endtinsert(fork_queue, co)--将协程加到fork_queue队列中 return co
end

从协程池中取出一个空闲协程，没有，则创建一个新的协程：

local function co_create(f)local co = tremove(coroutine_pool) --从协程池table末尾取出一个协程--协程池table为空，则创建新协程if co == nil thenco = coroutine_create(function(...)f(...)while true dolocal session = session_coroutine_id[co]if session and session ~= 0 thenlocal source = debug.getinfo(f,"S")skynet.error(string.format("Maybe forgot response session %s from %s : %s:%d",session,skynet.address(session_coroutine_address[co]),source.source, source.linedefined))end-- coroutine exitlocal tag = session_coroutine_tracetag[co]if tag ~= nil thenif tag then c.trace(tag, "end")   endsession_coroutine_tracetag[co] = nilendlocal address = session_coroutine_address[co]if address thensession_coroutine_id[co] = nilsession_coroutine_address[co] = nilend-- recycle co into poolf = nilcoroutine_pool[#coroutine_pool+1] = co--把新协程加入协程池-- recv new main function ff = coroutine_yield "SUSPEND"f(coroutine_yield())endend)else-- pass the main function f to coroutine, and restore running threadlocal running = running_threadcoroutine_resume(co, f)running_thread = runningendreturn co
end

处理fork_queue中的fork协程

function skynet.dispatch_message(...)local succ, err = pcall(raw_dispatch_message,...)--处理fork_queue中的fork协程while true dolocal co = tremove(fork_queue,1)if co == nil thenbreakendlocal fork_succ, fork_err = pcall(suspend,co,coroutine_resume(co))if not fork_succ thenif succ thensucc = falseerr = tostring(fork_err)elseerr = tostring(err) .. "\n" .. tostring(fork_err)endendendassert(succ, tostring(err))
end

skynet：fork相关推荐

Boost：fork守护程序的测试程序
Boost:fork守护程序的测试程序实现功能 C++实现代码实现功能 fork守护程序的测试程序 C++实现代码 #include <boost/asio/io_context.hpp&g ...
Boost：fork联接的测试程序
Boost:fork联接的测试程序实现功能 C++实现代码实现功能 boost::asio模块,fork联接的测试程序 C++实现代码 #include <boost/asio/execut ...
JAVA并行框架：Fork/Join
转载自 https://www.cnblogs.com/dongguacai/p/6021859.html JAVA并行框架:Fork/Join 一.背景虽然目前处理器核心数已经发展到很大数目,但是 ...
Java 7：Fork / Join框架示例
Java 7中的Fork / Join Framework专为可分解为较小任务的工作而设计,并将这些任务的结果组合起来以产生最终结果. 通常,使用Fork / Join Framework的类遵循以下 ...
Java并发编程(07)：Fork/Join框架机制详解
本文源码:GitHub·点这里 || GitEE·点这里一.Fork/Join框架 Java提供Fork/Join框架用于并行执行任务,核心的思想就是将一个大任务切分成多个小任务,然后汇总每个小任务 ...
Git协助方式：Fork项目开发新功能并使用Pull-Request把新特性推送给原项目
Git协助方式:Fork项目开发新功能并使用Pull-Request把新特性推送给原项目 Pull Request 是开发者使用 GitHub 进行协作的利器.这个功能为用户提供了友好的页面,让提议的 ...
Java7并发编程指南——第五章：Fork Join框架
Java7并发编程指南--第五章:Fork Join框架 @(并发和IO流) Java7并发编程指南第五章Fork Join框架思维导图项目代码思维导图项目代码 GitHub:Java7Con ...
CSAPP作业：Fork函数的学习感悟
在CSAPP课程学习中,教材的第八章:异常控制流中出现了一个名为Fork的函数,在书中提到它可以将一个进程复制为几乎相同却不完全相同的两个进程,被用于系统调用错误处理中,这使我对它产生了浓厚的兴趣. ...
使用 Git 的一点点疑惑：fork 跟 branch 的关系
一.引言最近在工作中接触到了一种 "别样" 的代码管理方式: 一个项目新建出来,先由项目负责人从主干的分支上 fork 出来一个仓库,然后各项目成员向这个 fork 出来的仓库中 ...

skynet：fork

一、测试

二、skynet.fork 原理

skynet：fork相关推荐

最新文章

热门文章