博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
nodelua
阅读量:5942 次
发布时间:2019-06-19

本文共 1402 字,大约阅读时间需要 4 分钟。

最近在学习go,对go中网络处理的方式比较喜欢,就用lua coroutine + C 模仿着接口实现一个玩具玩玩.

主要框架是lua导入C模块的时候会启动一个网络线程,lua和网络之间通过两个消息队列交互,lua将网络请求通过消息队列发送到C,

C将应答和网络事件通过消息队列发送到lua.

lua主线程运行在一个coroutine调度循环上,并不断的尝试从队列获得消息,一但收到消息就唤醒等待在此消息上阻塞的lua coroutine.

跟go的区别是,go routine是可以在多个处理器核心上运行的.

我在设计的时候也考虑过,是否将spwan函数也实现成多线程的,程序启动的时候开N个线程创建N个虚拟机跑coroutine调度器,spwan的

时候将这个创建请求分发到负载最轻的coroutine调度线程上 。但lua虚拟机之间传递数据并不是这么方便,实现起来也不是那么clean,所以

暂时放弃了这个念头.

下面贴一段nodelua的tcp echo服务示例:

require("nodelua")dofile("node/scheduler.lua")function doio(s)    print("doio")    while true do        local data,err = s:recv()        if err == "disconnected" then            print("a socket disconnect")            return        else            s:send(data)        end    endendfunction listen_fun(l)    print("listen_fun")    while true do        local s,err = l:accept()        if s then            node_spwan(s,doio) --spwan a light process to do io        elseif err == "stop" then            return        end    endendfunction main()            --local l,err = tcp_listen("127.0.0.1",8010)--arg[1],arg[2])    local l,err = tcp_listen(arg[1],arg[2])    if err then        print("listen error")        return    end    print("listen ok")    if l then        node_spwan(l,listen_fun) --spwan a light process to do accept    end    node_loop()    print("see you!")endmain()

目前nodelua只实现了对tcp的支持,还不完善,后续会慢慢完善.

 

 

 

转载于:https://www.cnblogs.com/sniperHW/p/3511182.html

你可能感兴趣的文章
常用Java8语法小结
查看>>
ZJOI2019 Day2 游记
查看>>
ccf题库中2015年12月2号消除类游戏
查看>>
WinForm窗体间如何传值
查看>>
Ado.Net 连接数据库
查看>>
java多线程系列1:Sychronized关键字
查看>>
解释性的语言vs编译性语言
查看>>
codevs 1105 过河
查看>>
Java三大主流框架概述
查看>>
【随想】_无关技术_你是合格的项目经理人吗?
查看>>
Codeforces round 1083
查看>>
Spring Boot Maven插件
查看>>
【转载】Deep learning:十九(RBM简单理解)
查看>>
SSL握手步骤【收藏】
查看>>
day29(对象转xml(使用java))
查看>>
[java]OutOfMemoryError 原因及解决办法
查看>>
Oracle调优总结
查看>>
Springboot - -web应用开发-Servlets, Filters, listeners
查看>>
正态分布
查看>>
[TFRecord文件格式]基本介绍
查看>>