Focus on ACE

?1 // @file:?ACEBaseApp.h
?2 // ???????把ACE集成到MFC帶界面程序的框架
?3 // @author:?jiangtao
?4 // @resvion?history;
?5 // @?version?0.1?2006-3-21?創建
?6 #ifndef?ACEBASE_APP_H
?7 #define ?ACEBASE_APP_H
?8 #pragma?once
?9 #include? " ace/ace.h "
10 #include? " ace/Reactor.h "
11 #include? " ace/Log_Msg.h "
12 #ifndef?_DEBUG
13 #pragma?comment(lib, " ace.lib " )
14 #else
15 #pragma?comment(lib, " aced.lib " )
16 #endif
17 class ?ACEBaseApp_T
18 {
19 ?? enum
20 ?? {
21 ????DEFAULT_ENENT_THREAD_NUM? = ? 4 ,
22 ??} ;
23 public :
24 ??ACEBaseApp_T( void );
25 ?? virtual ? ~ ACEBaseApp_T( void );
26 public :
27 ?? // 初始/結束ace框架
28 ?? virtual ? int ?init();
29 ?? virtual ? int ?fini();
30 public :
31 ?? // 啟動/結束事件循環
32 ?? virtual ? int ?startEventLoop();
33 ?? virtual ? int ?endEventLoop();
34
35 ?? // 與界面通訊的接口
36 ?? virtual ?CWnd * ?hostWnd();
37 ?? virtual ? void ?hostWnd(CWnd * ?wnd);
38
39 ?? // 找回反應器
40 ??ACE_Reactor * ?reactor( void );
41 ?? // 重新設置反應器
42 ?? void ?reactor(ACE_Reactor * ?r);
43
44 ?? // 執行事件循環的線程池
45 ?? static ?ACE_THR_FUNC_RETURN??eventLoop( void * );
46 private :
47 ??ACE_Reactor * ??reactor_;
48 ?? int ?eventThreadNum_;
49 ?? int ?dynamicCreate_;?
50 ??CWnd * ??hostWnd_;
51 } ;
52 #endif

??1 // @file:?ACEBaseApp.h
??2 // ???????把ACE集成到MFC帶界面程序的框架
??3 // @author:?jiangtao
??4 // @resvion?history;
??5 // @?version?0.1?2006-3-21?創建
??6
??7 #include? " StdAfx.h "
??8 #include? " ace/thread_manager.h "
??9 #include? " .\acebaseapp.h "
?10 #include? " ace/Tp_Reactor.h "
?11 ACE_THR_FUNC_RETURN?ACEBaseApp_T::?eventLoop?( void ? * arg)?
?12 {
?13 ??ACE_Reactor? * reactor? = ?static_cast < ACE_Reactor? *> ?(arg);
?14
?15 ??reactor -> owner?(ACE_OS::thr_self?());
?16 ??reactor -> run_reactor_event_loop?();
?17 ?? return ? 0 ;
?18 }
?19
?20 ACEBaseApp_T::ACEBaseApp_T( void )
?21 :reactor_( 0 ),eventThreadNum_(DEFAULT_ENENT_THREAD_NUM),dynamicCreate_( 0 )
?22 {
?23 ???
?24 }
?25
?26 ACEBaseApp_T:: ~ ACEBaseApp_T( void )
?27 {
?28 ?? if (dynamicCreate_)
?29 ?? {
?30 ????TRACE( " 釋放動態創建的TP?Reactor\n " );
?31
?32 ????delete?reactor_;
?33 ????reactor_? = ? 0 ;
?34 ??}
?35 }
?36
?37 int ?ACEBaseApp_T::init()
?38 {
?39 ?? return ??ace::init();
?40 }
?41 int ?ACEBaseApp_T::fini()
?42 {
?43 ?? return ?ace::fini();
?44 }
?45
?46 void ?ACEBaseApp_T::reactor(ACE_Reactor * ?r)
?47 {?
?48 ?? if (dynamicCreate_)
?49 ?? {
?50 ????delete?reactor_;
?51 ????dynamicCreate_? = ? 0 ;
?52 ??}
?53 ??reactor_? = ?r;
?54 }
?55
?56 ACE_Reactor * ?ACEBaseApp_T::reactor( void )
?57 {
?58 ?? if (reactor_? == ? 0 )
?59 ?? {
?60 ????TRACE( " 動態創建TP?Reactor\n " );
?61 ????ACE_TP_Reactor? * ?tp_reactor? = ? new ?ACE_TP_Reactor;
?62 ????ACE_Reactor? * ?my_reactor? = ? new ?ACE_Reactor(tp_reactor,? 1 );
?63 ????reactor(my_reactor);
?64 ????dynamicCreate_? = ? 1 ;
?65 ??}
?66
?67 ?? return ?reactor_;
?68 }
?69
?70 int ?ACEBaseApp_T::startEventLoop()
?71 {
?72 ??ACE_Thread_Manager::instance?() -> spawn_n
?73 ????(eventThreadNum_,?eventLoop,? this -> reactor());
?74
?75 ? return ? 0 ;
?76
?77 }
?78
?79 int ?ACEBaseApp_T::endEventLoop()
?80 {
?81
?82 ?? this -> reactor() -> end_reactor_event_loop();?
?83 ?? return ?ACE_Thread_Manager::instance?() -> wait?();
?84 }
?85
?86 void ?ACEBaseApp_T::hostWnd(CWnd * ?wnd)
?87 {
?88 ??hostWnd_? = ?wnd;
?89 }
?90
?91 CWnd * ?ACEBaseApp_T::hostWnd()
?92 {
?93 ?? if (hostWnd_? == ? 0 )
?94 ???? return ? 0 ;
?95 ?? if (::IsWindow(hostWnd_ -> m_hWnd))
?96 ?? {
?97 ???? return ?hostWnd_;
?98 ??}
?99 ?? else
100 ???? return ? 0 ;
101 }

1 #include? " ACEBaseApp.h "
2 class ?CACEAppApp?:? public ?CWinApp,
3 ??????????????????? public ?ACEBaseApp_T
4 {
5 public :
6 ????CACEAppApp();
7 // 略去無關的
8 } ;

?1 BOOL?CACEAppApp::InitInstance()
?2 {
?3 // ?略去無關的
?4 ????CWinApp::InitInstance();
?5 ??ACEBaseApp_T::init();??
?6 #if ?1
?7 ??ACE_TP_Reactor? * ?tp_reactor? = ? new ?ACE_TP_Reactor;
?8 ??ACE_Reactor? * ?my_reactor? = ? new ?ACE_Reactor(tp_reactor,? 1 );
?9 ??ACE_Reactor::instance(my_reactor,? 1 );
10 #endif
11 ??ACEBaseApp_T::reactor(ACE_Reactor::instance());
12 ??ACEBaseApp_T::startEventLoop();
13 // ?略去無關的????
14 ???? return ?FALSE;
15 }

1 int ?CACEAppApp::ExitInstance()
2 {
3 ?? // ?TODO:?Add?your?specialized?code?here?and/or?call?the?base?class
4 ??ACEBaseApp_T::fini();
5
6 ?? return ?CWinApp::ExitInstance();
7 }

1 ????te_? = ? new ?TimerEvent_T();
2 ????ACE_Reactor * ?r? = ?theApp.reactor();
3 ????ACE_Time_Value?t1( 1 );
4 ????ACE_Time_Value?t2( 2 );
5 ????r -> schedule_timer(te_, 0 ,t1,t2);

1 ??CACEAppDlg * ?dlg? = ?(CACEAppDlg * )?theApp.hostWnd();
2 ??ASSERT(dlg? != ? 0 );
3
4 ??dlg -> log( " time?out " );