当前位置:

首页 > 编程开发 > 浅谈chuck-lua中的多线程

浅谈chuck-lua中的多线程

chuck-lua采用actor模式实现多线程,每个线程运行独立Lua虚拟机。通过cthread.new创建线程,cthread.sendmail同步发送消息,邮箱满时发送方阻塞。消息自动序列化反序列化,禁止传递userdata。线程需注册process_mail处理消息,线程创建采用join模式。

本文目录

    chuck-lua 的多线程设计,走的是典型的 actor 模式。你可以通过 cthread.new 创建一个新线程,然后用 cthread.sendmail 把消息扔过去。跟 skynet 那种自带任务调度框架不太一样,chuck-lua 不负责帮你安排线程间的任务流转——每个线程自己维护一个简单的邮箱,其他线程发来的消息先缓存到里面,等着被处理。

    浅谈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()
    
    

    上面这段代码的逻辑很清楚:主线程启动监听,创建一个 worker 线程,每当有新的客户端连进来,就把 fd 通过 cthread.sendmail 扔给 worker 去处理。

    这里需要简单聊一下 chuck-lua 在线程方面的一些设计细节。

    因为每个线程都跑在独立的 Lua 虚拟机里,所以你不能直接通过消息把某个虚拟机里的对象传到另一个线程。目前 sendmail 会把作为消息传递的 Lua table 序列化成一种可传输的中间对象,目标线程收到后再重新反序列化成本地 VM 里的 table。好消息是,基本类型(number、string、table 等)都支持,但为了安全,userdata 类型是不允许直接传递的——这一点需要特别留意。

    另外,cthread.sendmail 是同步发送的。如果目标邮箱满了(达到了缓冲上限),发送方会被阻塞住。所以,所有期望接收邮件消息的线程都必须调用 cthread.process_mail 来注册消息回调函数。要是不注册,后果就是发送线程永远卡在那里,谁也跑不动。

    线程的创建采用 join 模式。也就是说,创建者可以通过 cthread.join 等待目标线程结束。这个设计和常见的线程同步方式一致,用起来比较直观。

    本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
    作者最新文章
    编程开发
    相关文章 更多
    编程语言的编程模型
    编程语言的编程模型

    编程模型涵盖面向过程的C语言、面向对象的Ruby、基于栈的PostScript、基于规则的Prolog、基于原型的Lua、函数式的Erlang/Haskell及混合模型的Scala/Clojure。类型系统区分强类型与弱类型、动态类型与静态类型,元编程允许运行时操作代码,提升表达力。

    lua 如何获取指定路径下的所有文件夹
    lua 如何获取指定路径下的所有文件夹

    Lua编程语言轻量级且小巧,可用io.popen执行系统命令获取指定路径下所有文件夹:在Windows系统下使用dir/b/s命令,在Unix系统下使用find-typef命令。然而官方更推荐使用lfs库进行递归遍历,通过lfs.dir和lfs.attributes函数筛选目录,此法避免系统命令依赖,代码简洁且跨平台效果更佳。

    lua调用C/C++的方法详解
    lua调用C/C++的方法详解

    Lua通过虚拟栈与C/C++交互,将C函数封装为接口供其调用。调用时,C从栈中获取参数并返回结果,参数传递与结果返回均通过栈操作完成,从而实现了Lua对C能力的高效、便捷调用,使得Lua能无缝利用C语言的高性能库。

    详解Lua中的元表和元方法
    详解Lua中的元表和元方法

    一、元表 元表是Lua中一个挺有意思的机制——它允许我们在一个值遇到未知操作时,给出自定义的行为。本质上,元表也是用table来承载的,所以熟悉了table,也就掌握了元表的基本用法。 不过得注意,元表只能针对一组预先定义好的操作集合做扩展,比面向对象中的类要受限得多。最典型的一点:元表不支持继承。

    如何使用Vim搭建Lua开发环境详解
    如何使用Vim搭建Lua开发环境详解

    基于SpaceVim搭建Lua开发环境,需先安装Neovim、Nerd字体及支持真色的终端,启用lang#lua模块后,即可获得全面的代码补全、语法检查、工程文件跳转、一键运行、代码格式化及交互式编程等高效开发功能,大幅提升编程效率与体验。

    Luvit像Node.js一样写Lua应用
    Luvit像Node.js一样写Lua应用

    先问个问题:如果你是一个Lua开发者,手头刚好有异步I/O的需求,你会怎么办?传统方案当然有,但要说最接近Node.js体验的,还得是Luvit。简单来说,它就是Lua界的Node.js——把Lua和libUV撮合在一起,再加上JIT加持,用项目自己的话说:Lua + libUV + JIT = p

    Lua流程控制语句if else的使用示例
    Lua流程控制语句if else的使用示例

    Lua的流程控制,if和if else是基础。和C语言很像,if语句支持嵌套,也能和循环配合——比如在循环体内根据条件决定是否跳出,这在日常开发中非常实用。 1、if语句 先看最基本的if语法结构: if(布尔表达式) then --[ 在布尔表达式为 true 时执行的语句 --] end 来看一

    Lua中pairs与ipairs的区别总结
    Lua中pairs与ipairs的区别总结

    最近在写一个流量转发的东西,用到了 nginx_lua_module 这个模块,需要根据 Header、Body 和 Cookie,按照流量比例把请求转发到其他地方。翻看前人留下的代码,发现循环遍历时,有时候用 pairs,有时候用 ipairs,风格并不统一,读起来让人有点困惑。 好在 Lua 官

    Lua游戏开发教程之时区问题详解
    Lua游戏开发教程之时区问题详解

    通过Lua的os.date("!*t")获取UTC时间,结合服务器时区差值,可将游戏内时间统一显示为服务器所在地时间。计算活动倒计时时,需考虑本地时区与服务器时区的差异,转换时间戳后得到准确剩余时间。正确处理时区问题能解决多语种发行中的显示同步难题。

    深入谈谈lua中神奇的table
    深入谈谈lua中神奇的table

    Lua中的table可作为字典、数组、环境、模块、对象和类使用。字典支持任意非nil键类型,遍历无序;数组索引从1开始,#对空洞处理需谨慎。table掌管全局环境_G和局部环境_ENV,模块本质为table。对象通过闭包实现私有成员,冒号语法糖简化self传递;类借助元表__index实现继承。

    查看更多
    精品专题 更多
    装机必备
    装机必备

    正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

    Windows
    Windows

    正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

    PDF教程
    PDF教程

    正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

    Mac软件 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    Aperty macOS版
    Aperty macOS版
    macOS

    Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

    WINDOWS 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    PixTV 网页版
    PixTV 网页版
    Windows

    PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。