module06 02 acereactor模塊簡介相關(guān)對象

CACEReactor?■◆■■●●●ACEC+■■■●●●●●●+zero:+max_time:-tv_:+ACE_Time_Value(sec:long,usec:long=+ACE_Time_Value(t:conststructtimeval+ACE_Time_Value(t:consttimespec_t+ACE_Time_Value(t:constFILETIME+set(sec:long,usec:+set(t:conststructtimeval+set(t:consttimespec_t+set(t:constFILETIME+sec():+usec():+msec():+operator+=(tv:constACE_Time_Value&):ACE_Time_Value+operator-=(tv:constACE_Time_Value&):ACE_Time_Value+operator*=(d:double):ACE_Time_Value■■■●●●●●●在其它的handle_*函數(shù)中的一個返回-1時，或是在事件類 描 異常事件，如緊急數(shù)據(jù)(outofbound)出現(xiàn)在socket ●●●事件類型priority_:reactor_:ACE_Reactor#ACE_Event_Handler(r:ACE_Reactor*=prio:int=+~ACE_Event_Handler+handle_input(h:ACE_HANDLE=ACE_INVALID_HANDLE):+handle_output(h:ACE_HANDLE=ACE_INVALID_HANDLE):+handle_exception(h:ACE_HANDLE=ACE_INVALID_HANDLE)+handle_timeout(now:ACE_Time_Value&,act:void*=:+handle_signal(signum:int,info:siginfo_t*=ctx:ucontext_t*=0):+handle_close(h:ACE_HANDLE,mask:ACE_Reactor_Mask)+get_handle():+reactor():ACE_Reactor+reactor(r:ACE_Reactor+priority():+priority(prio:■■■●●●2010-12-3112:08:12■■■●●●●●#reactor_#reactor_:ACE_Reactor#implementation_:ACE_Reactor_Impl+ACE_Reactor(implementation:ACE_Reactor_Impl=delete_implementation:int=+open(max_handlesint,restart:int=sig_handlerACE_Sig_Handler*=timer_queueACE_Timer_Queue*=0):+close():+register_handler(handler:ACE_Event_Handlermask:ACE_Reactor_Mask):

+register_handler(io:ACE_HANDLE,handler:ACE_Event_Handlermask:ACE_Reactor_Mask):+remove_handler(handler:ACE_Event_Handlermask:ACE_Reactor_Mask):+remove_handler(io:ACE_HANDLE,mask:ACE_Reactor_Mask):+remove_handler(hs:constACE_Handle_Set&,m:ACE_Reactor_Mask):int+suspend_handler(handler:ACE_Event_Handler*):+resume_handler(handler:ACE_Event_Handler*):+mask_ops(handler:ACE_Event_handlermask:ACE_Reactor_Mask,ops:int):+schedule_wakeup(handler:ACE_Event_Handler*,masks_to_be_added:ACE_Reactor_Mask):int+cancel_wakeup(handler:ACE_Event_Handler*,masks_to_be_cleared:ACE_Reactor_Mask):int+handle_events(max_wait_time:ACE_Time_Value*=0):

+run_reactor_event_loop(event_hook:int(*)(void*)=0):+end_reactor_event_loop():+reactor_event_loop_done():+schedule_timer(handler:ACE_Event_Handler*,arg:void*,delay:ACE_Time_Value&,repeat:ACE_Time_Value&=ACE_Time_Value::zero):+cancel_timer(handler:ACE_Event_Handlerdont_call_handle_close:int=1):+cancel_timer(timer_id:long,arg:void**=dont_call_handle_closeint1 +notify(handler:ACE_Event_Handler*=mask:ACE_Reactor_Mask=ACE_Event_Handler::EXCEPT_MASK,timeout:ACE_Time_Value*=0):int+max_notify_iterations(iterations:int):+purge_pending_notifications(handler:ACE_Event_Handler*,mask:ACE_Reactor_Mask=ALL_EVENTS_MASK):int+instance():ACE_Reactor+owner(new_owner:old_owner:ACE_thread_t*=0):

■■用結(jié)束時返回1■■●●●●■■●●●#include#include<ace/Reactor.h>#include<ace/TP_Reactor.h>#include<ace/Thread_Manager.h>#include<ace/Auto_Ptr.h>#includestaticACE_THR_FUNC_RETURNeventLoop(void{ACE_Reactor*reactor=static_cast<ACE_Reactor*>return0;}intmain()ParticipantAcceptoracceptor(ACE_Reactor::instance());A