浅谈chuck-lua中的多线程

local chuck = require("chuck")local engine = require("distri.engine")local socket_helper = chuck.socket_helperlocal Distri = require("distri.distri")local cthread = chuck.cthreadlocal worker function on_new_client(fd)  cthread.sendmail(worker,{fd})endlocal 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 = 8010if 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

local chuck = require("chuck")local socket = require("distri.socket")local engine = require("distri.engine")local clone  = chuck.packet.clonelocal cthread = chuck.cthreadlocal 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()