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

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