帮帮忙ACE_Condition问题

peakzhang

2. ACE_Thread_Mutex g_mutex;
3. ACE_Condition<ACE_Thread_Mutex> g_cond(g_mutex);
5. int g_requestNum = 1;
7. class CMyTask : public ACE_Task<ACE_MT_SYNCH>
8. {
9. public:
11. CMyTask()
12. {
14. }
16. int svc()
17. {
18.   ACE_DEBUG((LM_DEBUG,"Thread <%t> enter time: %T\n"));
20.   if (g_requestNum < 1)
21.   {
22.    g_cond.wait();   
23.    }
25.   --g_requestNum;
27.   ACE_DEBUG((LM_DEBUG,"Thread <%t> exit time: %T\n"));
28.   return 0;
29. }
31. int open(void)
32. {
33.   ACE_DEBUG((LM_DEBUG,"Thread <%t> open!\n"));
34.   this->activate(THR_NEW_LWP | THR_JOINABLE,3);
35.   return 0;
36. }
38. int close(u_long flags)
39. {
40.   ACE_DEBUG((LM_DEBUG,"Thread <%t> close!\n"));
41.   return 0;
42. }
45. protected:
46. private:
48. };
51. int main(int argc, char* argv[])
52. {
54. CMyTask oCMyTask;
55. oCMyTask.open();
58. int sw = 0;
59. std::cin<<sw;
60. if (sw == 1)
61. {
62.   ++g_requestNum;
63.   ::g_cond.signal();   //执行后等待的线程没有继续执行，不知道哪里错了。
64. }
66. return 0;
67. }

复制代码

peakzhang

2. #include "ace/Task.h"
3. #include "ace/Synch.h"
4. #include "ace/IOStream.h"
6. ACE_Thread_Mutex g_mutex;
7. ACE_Condition<ACE_Thread_Mutex> g_cond(g_mutex);
9. int g_requestNum = 1;
11. class CMyTask: public ACE_Task<ACE_MT_SYNCH>
12. {
13. public:
14. CMyTask(){}
16. int svc()
17. {
18.   ACE_DEBUG((LM_DEBUG, "Thread <%t> enter time: %T\n"));
19.   if( g_requestNum == 1 ){
20.    g_cond.wait();
21.   }
22.   -- g_requestNum;
23.   ACE_DEBUG((LM_DEBUG, "Thread <%t> exit time: %T\n"));
24.   return 0;
25. }
27. int open(void)
28. {
29.   ACE_DEBUG((LM_DEBUG, "Thread <%t> open!\n"));
30.   this->activate(THR_NEW_LWP| THR_JOINABLE, 3);
31.   return 0;
32. }
34. int close(u_long flags)
35. {
36.   ACE_DEBUG((LM_DEBUG, "Thread <%t> close!\n"));
37.   return 0;
38. }
39. protected:
40. private:
41. };
44. int main(int argc, char* argv[])
45. {
46. CMyTask oCMyTask;
47. oCMyTask.open();
49. int sw = 1;
51. for( int i = 0 ; i < 3 ; i++)
52. {
53.   ++ g_requestNum;
54.   ::g_cond.signal();
55. }
57. oCMyTask.wait();
58. return 0;
59. }

复制代码

蛮好的了，不知道你是指什么意思

peakzhang

这几天调试代码发现有点错误

2. #include<iostream>
3. #include <ace/Synch.h>
4. #include<ace/Task.h>
5. using namespace std;
7. ACE_Thread_Mutex g_mutex;
8. ACE_Condition<ACE_Thread_Mutex> g_cond(g_mutex);
9. int g_requestNum = 1;   //只有一个资源可以使用
10. class CMyTask : public ACE_Task<ACE_MT_SYNCH>
11. {
12. public:
13. CMyTask()
14. {
15. }
16. int svc()
17. {
18.   ACE_DEBUG((LM_DEBUG,"Thread <%t> enter time: %T\n"));
19.   if (g_requestNum < 1)
20.   {
21.    g_cond.wait();   //资源数不足，将线程等待
22.    }
23.   --g_requestNum; //资源使用完后，将资源数置减1
24.   ACE_DEBUG((LM_DEBUG,"Thread <%t> exit time: %T\n"));
25.   return 0;
26. }
27. int open(void)
28. {
29.   ACE_DEBUG((LM_DEBUG,"Thread <%t> open!\n"));
30.   this->activate(THR_NEW_LWP | THR_JOINABLE,3);  //定义3个线程
31.   return 0;
32. }
33. int close(u_long flags)
34. {
35.   ACE_DEBUG((LM_DEBUG,"Thread <%t> close!\n"));
36.   return 0;
37. }
39. protected:
40. private:
41. };
43. int main(int argc, char* argv[])
44. {
45. CMyTask oCMyTask;
46. oCMyTask.open();
47. int sw = 0;
48. while (true)
49. {
50.   cin>>sw;
51.   if (sw == 1)
52.   {
53.    ++g_requestNum;  //输入1后增加一个资源
54.    ::g_cond.signal();  //资源增加后唤醒等待的线程，但是问题就是等待的线程没有启动，
55.                        //不知道是怎么回事？请大家帮着看看！
56.   }
57. }
59. return 0;
60. }

复制代码

peakzhang

if (g_requestNum < 1)   这里一开始 g_requestNum = 1,怎么等待？
  {
   g_cond.wait();   //资源数不足，将线程等待
   }

peakzhang

到今天我已经知道了原因,特发表：
ACE_Thread_Mutex g_mutex;
ACE_Condition<ACE_Thread_Mutex> g_cond(g_mutex);
int g_requestNum = 1;
class CMyTask : public ACE_Task<ACE_MT_SYNCH>
{
public:
CMyTask()
{
}
int svc()
{
  ACE_DEBUG((LM_DEBUG,"Thread <%t> enter time: %T\n"));
  g_mutex.aquire();
  if (g_requestNum < 1)
  {
   g_cond.wait();   
   }
  --g_requestNum;
  g_mutex.release();
  ACE_DEBUG((LM_DEBUG,"Thread <%t> exit time: %T\n"));
  return 0;
}
int open(void)
{
  ACE_DEBUG((LM_DEBUG,"Thread <%t> open!\n"));
  this->activate(THR_NEW_LWP | THR_JOINABLE,3);
  return 0;
}
int close(u_long flags)
{
  ACE_DEBUG((LM_DEBUG,"Thread <%t> close!\n"));
  return 0;
}

protected:
private:
};

int main(int argc, char* argv[])
{
CMyTask oCMyTask;
oCMyTask.open();

int sw = 0;
std::cin<<sw;
if (sw == 1)
{
  ++g_requestNum;
  ::g_cond.signal();
}
return 0;
}