Reactor事件的问题！

peakzhang

我把ACE_Reactor::instance()->run_reactor_event_loop();  放在我的主线程中，我的定时器就正常!
如果我把ACE_Reactor::instance()->run_reactor_event_loop();放在子线程中，为什么我的定时器就不起作用了呢？
定时器也不会出错！！！

peakzhang

//
// 这是测试代码！
//

1. #include
2. #include
3. #include "ace/Task_T.h"
4. #include "ace/Reactor.h"
5. #include "ace/Event_Handler.h"
7. class A : public ACE_Task
8. {
9. public:
10. int svc(void)
11. {
12.   while(ACE_Reactor::instance()->reactor_event_loop_done() == 0)
13.    ACE_Reactor::instance()->run_reactor_event_loop();
15.   return 0;
16. }
18. int stop(void)
19. {
20.   ACE_Reactor::instance()->end_reactor_event_loop();
21.   return 0;
22. }
24. int start(int nThread = 1)
25. {
26.   this->activate(THR_NEW_LWP|THR_JOINABLE|THR_INHERIT_SCHED, nThread);
27.   return 0;
28. }
31. };
33. class B : public ACE_Event_Handler
34. {
35. public:
36.    virtual int handle_timeout (const ACE_Time_Value ¤t_time,
37.                               const void *act = 0)
38.    {
39.     ACE_DEBUG((LM_DEBUG, "..................\n"));
40.     return 0;
41.    }
42. };
44. int ACE_TMAIN(int argc, ACE_TCHAR *argv[])
45. {
46. A a;
47. B b;
48. a.start();
50. ACE_Time_Value const timeout(3);
51. if (ACE_Reactor::instance()->schedule_timer(&b, 0, timeout, timeout) == -1)
52.   ACE_ERROR((LM_ERROR, ACE_TEXT("(%t) %p\n"), ACE_TEXT("schedule_timer")));
55. a.wait();  // 用这个，定时器就无效！
56. //ACE_Reactor::instance()->run_reactor_event_loop();  // 用这个没有问题！正常！
57. return 0;
58. }

复制代码

peakzhang

修改你的

int A::svc(void),增加

ACE_Reactor::instance()->owner(ACE_OS::self());

peakzhang

补上完整的测试代码,VC2005/xp下通过

1. /**
2. test.cpp
3. Stone jiang
4. */
6. #include "ace/OS_NS_time.h"
7. #include "ace/Log_Msg.h"
8. #include "ace/Reactor.h"
9. #include "ace/Event_Handler.h"
10. #include "ace/Task.h"
11. #include "ace/Thread_Manager.h"
12. #include "ace/TP_Reactor.h"
13. #include "ace/WFMO_Reactor.h"
15. class MyTimerHandler : public ACE_Event_Handler
16. {
17. public:
18.     int handle_timeout (const ACE_Time_Value ¤t_time,
19.         const void * = 0)
20.     {
21.         time_t epoch = ((timespec_t)current_time).tv_sec;
23.         ACE_DEBUG ((LM_INFO,
24.             ACE_TEXT ("(%t) handle_timeout: %s\n"),
25.             ACE_OS::ctime (&epoch)));
27.         return 0;
28.     }
29. };
31. class SigintHandler : public ACE_Event_Handler
32. {
33. public:
34.     int handle_signal (int signum, siginfo_t * = 0,
35.         ucontext_t * = 0)
36.     {
37.         if (signum == SIGINT)
38.         {
39.             ACE_Reactor::instance ()->end_reactor_event_loop ();
40.         }
41.         return 0;
42.     }
43. };
45. class ReactorThread :public ACE_Task
46. {
47. public:
48.     ReactorThread(void* r)
49.     {
50.         reactor_ = (ACE_Reactor*) r;
52.         ACE_DEBUG ((LM_INFO,
53.             ACE_TEXT ("ReactorThread::ReactorThread()\n")));
54.         this->activate(THR_NEW_LWP | THR_JOINABLE | THR_INHERIT_SCHED,3);
55.     }
56.     virtual int svc()
57.     {
58.         ACE_DEBUG ((LM_INFO,
59.             ACE_TEXT (" (%t) ReactorThread::svc()\n")));
60.            reactor_->owner (ACE_OS::thr_self ());
61.            reactor_->run_reactor_event_loop();
62.            return 0;
63.     }
65. private:
66.    ACE_Reactor* reactor_;
68. };
69. int ACE_TMAIN (int, ACE_TCHAR *[])
70. {
71.       
72.     ACE_DEBUG ((LM_INFO,
73.         ACE_TEXT ("(%t) main::start \n")));
75.     ACE_WFMO_Reactor this_reactor;
76.     ACE_Reactor reactor (&this_reactor);
77.     auto_ptr delete_instance
78.     (ACE_Reactor::instance (&reactor));
80.     ReactorThread thread(ACE_Reactor::instance());
81.     MyTimerHandler * timer = new MyTimerHandler ();
82.     ACE_Time_Value initialDelay (1);
83.     ACE_Time_Value interval (2);
84.     ACE_Reactor::instance()->schedule_timer (timer,
85.         0,
86.         initialDelay,
87.         interval);
88.    
89.     SigintHandler * handleExit = new SigintHandler ();
90.     ACE_Reactor::instance()->register_handler (SIGINT,
91.         handleExit);
93.   thread.wait();
95.     ACE_DEBUG ((LM_INFO,
96.         ACE_TEXT ("main::exit \n")));
97.     return 0;
98. }

复制代码

peakzhang

stone正解，测试了一下，的确如此。
svc改成：
  while(ACE_Reactor::instance()->reactor_event_loop_done() == 0)
  {
   ACE_Reactor::instance()->owner(ACE_OS::thr_self ());
   ACE_Reactor::instance()->run_reactor_event_loop();
  }
即完全正常。

原因是：
set the owner of the reactor to the identity of the thread that runs the event loop

peakzhang

The thread which is "owner" of the WFMO_Reactor. The owner
concept is used because we don't want multiple threads to try to
expire timers. Therefore the "owner" thread is the only one
allowed to expire timers. Also, the owner thread is the only
thread which waits on the notify handle. Note that the ownership
can be transferred.