手机版
你好,游客 登录 注册 搜索
背景:
阅读新闻

Lua 架构构建多线程事物性线程

[日期:2012-11-24] 来源:Linux社区  作者:xueyunf [字体: ]

Lua与C++的调用本文虽然有涉及但是,这不是我今天向大家推荐的内容,今天向大家写的示例代码是Lua如何构建控制和任务逻辑以及与主线程进行控制子线程程执行的方式。

不熟悉Windows下多线程的童鞋可以翻翻本人的多线程的相关文章,也可以自己从网上学习下多线程的编写,以及如何合理的退出线程。这样编写代码可以做到,架构灵活,业务可变更性非常强,只要实现好底层算法性代码,业务逻辑尽量交给脚本语言吧,查错方便,直接可以定位到具体的行数,这是C++不具备的,当然上层用Lua方便的同时,增加了编写C++注册到Lua的函数的人负担,他必须非常清楚的了解Lua和C++的特性,但是对于分别编写Lua和C++的两拨人将非常轻松,这样团队只需要一个C++能人和一些中级的C++程序员,和一堆对编程了解不多的Lua程序员就可以完成复杂的业务逻辑工作。最适合团队中只要一个技术大神的团队或者团队中的大神非常少的情况。这样设计从根本上屏蔽了对C++多线程的了解,Lua程序员就可以处理多线程并发事物,他可以不知道何为原子操作,可以不知道何为关键段何为等待事物,这些全部交给一个去编写完成,其他Lua程序员只需要调用即可,而不是神级的C++程序员只用来开发底层费时间的运算即可。非常适合快速开发。若后期觉得提高效率非常必要,那就将Lua写成C++。

  1. #include <stdio.h> 
  2. #include <iostream> 
  3. #include <Windows.h> 
  4. #include <vector> 
  5.  
  6.  
  7. #pragma comment(lib,"lua.lib") 
  8. using namespace std; 
  9.  
  10.  
  11. extern "C" { 
  12. #include "lua/lua.h" 
  13. #include "lua/lualib.h" 
  14. #include "lua/lauxlib.h" 
  15.  
  16.  
  17. lua_State* L; 
  18. lua_State* L2; 
  19.  
  20.  
  21. int average(lua_State *L) 
  22.     int n=lua_gettop(L); 
  23.     double sum=0; 
  24.     for (int i=0;i<=n;i++) 
  25.     { 
  26.         sum+=lua_tonumber(L,i); 
  27.     } 
  28.     lua_pushnumber(L,sum/n); 
  29.     lua_pushnumber(L,sum); 
  30.     lua_pushnumber(L,n); 
  31.     /*标识函数有几个返回值*/ 
  32.     return 3; 
  33. HANDLE MyEvent; 
  34. HANDLE MyExit; 
  35. volatile unsigned long threadRun; 
  36.  
  37.  
  38. struct ThreadInfo 
  39.     string Text; 
  40.      
  41.     string DataPath; 
  42.  
  43.  
  44.     int    NextPosition; 
  45.  
  46.  
  47.     bool   boolValue; 
  48. }; 
  49.  
  50.  
  51. vector <int(*)(ThreadInfo InputThreadInfo,ThreadInfo &OutputThreadInfo)> FunctionVector; 
  52.  
  53.  
  54. int AddFunction(int(*_ProcesseFunction)(ThreadInfo InputThreadInfo,ThreadInfo &OutputThreadInfo)) 
  55.     FunctionVector.push_back(_ProcesseFunction); 
  56.     return 0; 
  57.  
  58.  
  59. ThreadInfo myInputInfo; 
  60.  
  61.  
  62. static unsigned long WINAPI MyThreadFunction(LPVOID lpvoid) 
  63.     myInputInfo.boolValue    = false; 
  64.     myInputInfo.DataPath     = "kji"; 
  65.     myInputInfo.NextPosition = 0; 
  66.     myInputInfo.Text         = "Hello World!"; 
  67.     ThreadInfo myOutPutInfo; 
  68.      
  69.     while(1) 
  70.     { 
  71.         WaitForSingleObject(MyEvent,INFINITE); 
  72.         ResetEvent(MyEvent); 
  73.         if(0==threadRun) 
  74.         { 
  75.             break; 
  76.         } 
  77.         for (int i=0;i<(int)(FunctionVector.size());i++) 
  78.         { 
  79.             if (NULL!=(FunctionVector[i])) 
  80.             { 
  81.                 (*FunctionVector[i])(myInputInfo,myOutPutInfo); 
  82.             } 
  83.         }         
  84.     } 
  85.     SetEvent(MyExit); 
  86.     return 0; 
  87.  
  88.  
  89. int PointFunction(ThreadInfo InputThreadInfo,ThreadInfo &OutputThreadInfo) 
  90.     OutputThreadInfo.boolValue=!InputThreadInfo.boolValue; 
  91.     OutputThreadInfo.DataPath= InputThreadInfo.DataPath; 
  92.     OutputThreadInfo.NextPosition = InputThreadInfo.NextPosition+1; 
  93.     OutputThreadInfo.Text = InputThreadInfo.Text; 
  94.  
  95.  
  96.     printf("%s \n",OutputThreadInfo.Text); 
  97.     /* 运行脚本 */ 
  98.     luaL_dofile(L2, "2.lua"); 
  99.  
  100.  
  101. int startWork(lua_State *L) 
  102.     SetEvent(MyEvent); 
  103.     return 0; 
  104.  
  105.  
  106. int Exit(lua_State *L) 
  107.     InterlockedExchange(&threadRun,0); 
  108.     SetEvent(MyEvent); 
  109.     return 0; 
  110.  
  111.  
  112. int CreateMythread(LPVOID lpvoid) 
  113.     MyEvent = CreateEvent(NULL,TRUE,FALSE,L"startProcess"); 
  114.     MyExit  = CreateEvent(NULL,TRUE,FALSE,L"ExitEvent"); 
  115.     InterlockedExchange(&threadRun,1); 
  116.     DWORD dwthreadID; 
  117.     HANDLE ThreadHandle = CreateThread(NULL,NULL,MyThreadFunction,lpvoid,0,&dwthreadID); 
  118.     if (NULL==ThreadHandle) 
  119.     { 
  120.         CloseHandle(ThreadHandle); 
  121.         return 1; 
  122.     } 
  123.     CloseHandle(ThreadHandle); 
  124.     return 0; 
  125.  
  126.  
  127.  
  128.  
  129. int main ( int argc, char *argv[] ) 
  130.     AddFunction(PointFunction); 
  131.     CreateMythread(NULL); 
  132.  
  133.  
  134.     /* 初始化Lua */ 
  135.     L=luaL_newstate(); 
  136.     lua_status(L); 
  137.  
  138.  
  139.     /* 载入Lua基本库 */ 
  140.     luaL_openlibs(L); 
  141.  
  142.  
  143.     /*注册函数*/ 
  144.      
  145.     L2=luaL_newstate(); 
  146.     lua_status(L2); 
  147.  
  148.  
  149.     /* 载入Lua基本库 */ 
  150.     luaL_openlibs(L2); 
  151.  
  152.  
  153.     /*注册函数*/ 
  154.  
  155.  
  156.     lua_register(L2,"average",average); 
  157.  
  158.  
  159.     lua_register(L,"startWork",startWork); 
  160.  
  161.  
  162.     lua_register(L,"ExitAllThread",Exit); 
  163.     /* 运行脚本 */ 
  164.     luaL_dofile(L, "1.lua"); 
  165.  
  166.  
  167.  
  168.  
  169.  
  170.  
  171.     WaitForSingleObject(MyExit,INFINITE); 
  172.     ResetEvent(MyExit); 
  173.     CloseHandle(MyExit); 
  174.     CloseHandle(MyEvent); 
  175.     /* 清除Lua */ 
  176.     lua_close(L); 
  177.     lua_close(L2); 
  178.     /* 暂停 */ 
  179.     system("pause"); 
  180.  
  181.  
  182.     return 0; 
linux
相关资讯       Lua  Lua多线程  Lua线程 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款