模拟ATM取钱动作，不加锁可能为负数，加了锁就不会了

子牛

1. // test.cpp : Defines the entry point for the console application.
2. //
4. #include "stdafx.h"
5. #include "../../include/ace/ACE.h"
6. #include "../../include/ace/Log_Msg.h"
7. #include "../../include/ace/Singleton.h"
8. #include "../../include/ace/Null_Mutex.h"
9. #include "../../include/ace/OS.h"
11. #include "../../include/ace/Thread_Mutex.h"
12. #include "../../include/ace/Global_Macros.h"
14. #pragma comment( lib, "libace32.lib")
17. class config_data
18. {
19. public:
20.         config_data();
21.         ~config_data();
23.         void add();
24. };
26. config_data::config_data()
27. {
28.         ACE_DEBUG((LM_INFO, ACE_TEXT("[%M][%T][%t] load route: %s\n"), "config_data()"));
29. }
31. config_data::~config_data()
32. {
33.         ACE_DEBUG((LM_INFO, ACE_TEXT("[%M][%T][%t] load route: %s\n"), "~config_data()"));
34. }
36. void config_data::add()
37. {
38.         ACE_DEBUG((LM_INFO, ACE_TEXT("[%M][%T][%t] load route: %s\n"), "add()"));
39. }
40. typedef ACE_Singleton<config_data,ACE_Null_Mutex> GAME_CONFIG;
43. ACE_Thread_Mutex  tableptr_storm_lock;
46. #include "ace/Log_Msg.h"
47. #include "ace/OS.h"
48. #include "ace/Thread.h"
49. #include "ace/Task.h"
51. int num=0;
52. class CommandHandler: public ACE_Task_Base
53. {
54. private:
55.         static int nThreadNum;
57. public:
58.         virtual int svc(void)
59.         {
60.                 int nThreadID = 0;
61.                 int i = 0;
63.                 nThreadNum++;
64.                 nThreadID = nThreadNum;
65.                 ACE_DEBUG( (LM_INFO, ACE_TEXT("thread[%t] %d start\n"), nThreadID) );
66.                 ACE_OS::sleep(1);
68.                 while(i <= 100)
69.                 {
70.                         i++;
71.                         ACE_OS::sleep(1);
73.                         {
74.                                 num++;
75.                                
76.                                 {
77.                                         ACE_DEBUG( (LM_INFO, ACE_TEXT("thread[%t] num = %d \n"), num) );
78.                                 }
79.                         }
80.                 }
81.                 return nThreadID;
82.         }
83. };
86. class CommandHandler1: public ACE_Task_Base
87. {
88. public:
89.         virtual int svc(void)
90.         {
91.                 int nThreadID = 0;
92.                 int i = 0;
94.                 ACE_DEBUG( (LM_INFO, ACE_TEXT("thread[%t]  start\n")) );
95.                 ACE_OS::sleep(1);
97.                 while(i <= 100)
98.                 {
99.                        
100.                         i++;
101.                        
103.                         {
104.                                 ACE_GUARD_RETURN(ACE_Thread_Mutex,g,tableptr_storm_lock,-1);
106.                                 int aa=num;
107.                                 if(num>0)
108.                                 {
109.                                         ACE_OS::sleep(2);
110.                                         num-=aa;
111.                                 }
112.                                
113.                                
114.                                         ACE_DEBUG( (LM_INFO, ACE_TEXT("--thread[%t] num = %d \n"), num) );
115.                                
116.                                
117.                         }
118.                         ACE_OS::sleep(1);
119.                 }
120.                 return nThreadID;
121.         }
122. };
124. int CommandHandler::nThreadNum = 0;
127. int _tmain(int argc, _TCHAR* argv[])
128. {
129.         GAME_CONFIG::instance()->add();
130.         GAME_CONFIG::instance()->add();
131.         ACE_DEBUG((LM_INFO, ACE_TEXT("[%M][%T][%t] load route: %s\n"), "test"));
133.        
135.         int nReturn = 0;
136.         CommandHandler cmd;
137.         CommandHandler1 cmd1;
139.         nReturn = cmd.activate(THR_NEW_LWP|THR_JOINABLE,1);//存钱线程
140. ACE_OS::sleep(1);
141.         cmd1.activate(THR_NEW_LWP|THR_JOINABLE,20);//取钱线程，假设有20个人在不同的ATM机器上取
143.         if(nReturn != 0)
144.         {
145.                 ACE_DEBUG( (LM_ERROR, ACE_TEXT("failed to active this thread[%d] %p\n"), nReturn, ACE_TEXT("active")) );
146.                 return -1;
147.         }
149.         /*ACE_OS::sleep(10);
150.         ACE_DEBUG( (LM_INFO, ACE_TEXT("Suspend this thread ......\n")) );
151.         cmd.suspend();
152.         ACE_OS::sleep(10);
153.         ACE_DEBUG( (LM_INFO, ACE_TEXT("Resume this thread ......\n")) );
154.         cmd.resume();*/
155.         cmd.wait();
159.         return 0;
160. }

复制代码