chuck-lua支持actor模式的线程模型.可以通过cthread.new创建线程,然后通过cthread.sendmail向线程发送消息.
与skynet这种框架不同,chuck-lua并不提供多线程的任务/消息调度功能,每个线程维护了一个简单的线程邮箱,用于缓存其它线程发过来的消息.
下面看一个简单的多线程服务器示例:
mtserver.lua
local chuck = require("chuck")
local engine = require("distri.engine")
local socket_helper = chuck.socket_helper
local Distri = require("distri.distri")
local cthread = chuck.cthread
local worker
function on_new_client(fd)
cthread.sendmail(worker,{fd})
end
local fd = socket_helper.socket(socket_helper.AF_INET,
socket_helper.SOCK_STREAM,
socket_helper.IPPROTO_TCP)
socket_helper.addr_reuse(fd,1)
local ip = "127.0.0.1"
local port = 8010
if 0 == socket_helper.listen(fd,ip,port) then
print("server start",ip,port)
local server = chuck.acceptor(fd)
server:Add2Engine(engine,on_new_client)
Distri.Signal(chuck.signal.SIGINT,Distri.Stop)
worker = cthread.new("distri/test/worker.lua")
Distri.Run()
end
worker.lua
local chuck = require("chuck")
local socket = require("distri.socket")
local engine = require("distri.engine")
local clone = chuck.packet.clone
local cthread = chuck.cthread
local Distri = require("distri.distri")
--设置邮件处理函数
cthread.process_mail(engine,function (sender,mail)
local fd = table.unpack(mail)
local s = socket.stream.New(fd)
if s:Ok(4096,socket.stream.decoder.rawpacket(),function (_,msg,errno)
if msg then
s:Send(clone(msg))
else
s:Close(errno)
s = nil
end
end) then
s:SetRecvTimeout(5000)
else
s:Close()
end
end)
Distri.Run()
这个示例很简单,主线程启动监听,创建一个线程,当接收到连接时就将fd发送给worker线程.
在这里需要简单介绍一下chuck-lua线程相关的一些细节.
因为各线程跑在独立的虚拟机上,因此无法直接通过消息的方式将一个虚拟机中的对象发送到另一个线程中.目前sendmail将作为消息传递给它的lua table序列化为一种适合传输的对象,目标线程接收这个对象之后再重新转化成本线程虚拟机中的lua table.目前消息支持lua中的所有基本类型,但为了安全考虑,不支持直接传递userdata类型.
用cthread.sendmail向目标线程发送消息时,如果到达目标邮箱的缓冲上线将会阻塞.所有期望处理邮件消息的线程都必须调用cthread.process_mail设定消息回调函数.如果不设定,将可能导致消息发送线程永久阻塞.
线程使用join模式创建,创建者可以通过cthread.join等待线程的结束.
以上所述就是本文的全部内容了，希望大家能够喜欢。
chuck-lua,多线程
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。