一動不如一靜

/**/ /* *******************************************************************
*?Copyright?(c)?2006,study-record?home
*?All?rights?reservered.
*
*?文件名稱?:?littersize.cpp?
*?摘????要?:?這個例子主要是用來驗證這樣一個問題。當(dāng)我們程序中有n個reactor的時候，是否就意味著我們支持n*FD_SETSIZE連接.
???????????????????為了驗證這個問題,我們傳遞一個大小為2的值給ACE_Select_Reactor的構(gòu)造函數(shù)?？词欠袷侵恢С?個連接?
???????????????????驗證結(jié)果表明：在本例子中，由于acceptor注冊用掉了一個，而我們給定的最大的handle數(shù)為2,所以只能接受一個連接。
???????????????????在命令行下輸入：telnet?127.0.0.1?1234?,在我們第二次輸入時，
???????????????????在調(diào)用int?nRet?=?m_Reactor->register_handler(pEvent,?ACE_Event_Handler::READ_MASK);的時候一定會失敗。
???????????????????但是在命令行下輸入:telnet?127.0.0.1?2345?,在我們第三次輸入的時候，調(diào)用register_handler的時候才會失敗
???????????????????但是這樣的一段代碼存在高cpu的問題，也就是當(dāng)把客戶端關(guān)調(diào)的時候，cpu占用率會很高?想想看，為什么呢？
???????????????????本代碼只是為了驗證一些東西，有很多不合理的地方，請務(wù)仿照。
*
*?當(dāng)前版本?:?1.0
*?作????者?:?study-record???2007-2-22
*
******************************************************************** */

#include? " ace/Thread_Manager.h "
#include? " ace/Select_Reactor.h "
#include? " ace/Reactor.h "
#include? " ace/Event_Handler.h "
#include? " ace/SOCK_Acceptor.h "
#include? " ace/SOCK_Stream.h "
#include? " ace/INET_Addr.h "

const ?size_t?g_unOneMaxHandle? = ? 2 ;
const ?size_t?g_unTwoMaxhandle? = ? 4 ;


static ?ACE_THR_FUNC_RETURN?event_loop_one?( void ? * arg)?
{
????ACE_Reactor? * reacator? = ?static_cast < ACE_Reactor? *> (arg);

????reacator -> owner(ACE_Thread::self());
????reacator -> run_reactor_event_loop();
???? return ? 0 ;

}
static ?ACE_THR_FUNC_RETURN?event_loop_two?( void ? * arg)?
{
????ACE_Reactor? * reacator? = ?static_cast < ACE_Reactor? *> (arg);

????reacator -> owner(ACE_Thread::self());
????reacator -> run_reactor_event_loop();
???? return ? 0 ;
}

class ?TestHandleEvent:? public ?ACE_Event_Handler
{
public :
???? virtual ? int ?handle_input?(ACE_HANDLE?fd? = ?ACE_INVALID_HANDLE)
???? {
????????ACE_DEBUG((LM_DEBUG,? " TestHandleEvent::handle_input\n " ));
???????? return ? 0 ;
????} ;
???? virtual ? int ?handle_close?(ACE_HANDLE?handle,?ACE_Reactor_Mask?close_mask)
???? {
????????
????????ACE_DEBUG((LM_DEBUG,? " TestHandleEvent::handle_close\n " ));
????????delete? this ;
???????? return ? 0 ;

????} ;
????ACE_HANDLE?get_handle( void )? const ?
???? {
???????? return ?peer.get_handle();
????}

public :
????ACE_SOCK_Stream?peer;

} ;
class ?TestAcceptor?:? public ?ACE_Event_Handler
{
public :
???? virtual ? int ?handle_input?(ACE_HANDLE?fd? = ?ACE_INVALID_HANDLE)
???? {
????????
????????TestHandleEvent * ?pEvent? = ? new ?TestHandleEvent;
????????acceptor.accept(pEvent -> peer);
???????? int ?nRet? = ?m_Reactor -> register_handler(pEvent,?ACE_Event_Handler::READ_MASK);
???????? if ?( - 1 ? == ?nRet)
???????? {
????????????delete?pEvent;
????????????pEvent? = ?NULL;
????????}

???????? return ? 0 ;
????} ;
???? virtual ? int ?handle_close?(ACE_HANDLE?handle,?ACE_Reactor_Mask?close_mask)
???? {
????????ACE_DEBUG((LM_DEBUG,? " TestAcceptor::handle_close\n " ));
????????acceptor.close();
????????delete? this ;

???????? return ? 0 ;

????} ;
????
????
????TestAcceptor(ACE_Reactor * ?reactor):m_Reactor(reactor)
???? {
????????
????} ;
???? int ?open(unsigned? short ?usport)
???? {
????????ACE_INET_Addr?addr(usport);
????????acceptor.open(addr);
???????? return ?m_Reactor -> register_handler( this ,?ACE_Event_Handler::ACCEPT_MASK);

????} ;
????ACE_HANDLE?get_handle( void )? const ?
???? {
????????
???????? return ?acceptor.get_handle();
????}
public :
????ACE_SOCK_Acceptor?acceptor;
????ACE_Reactor * ?m_Reactor;

} ;


int ?main?( int ?argc,? char ? * argv[])
{
????

????ACE_Select_Reactor?select_reactor_one(g_unOneMaxHandle,? 0 ,? 0 ,? 0 ,? 1 );
????ACE_Reactor * ?reactor_one? = ? new ?ACE_Reactor( & select_reactor_one);

????ACE_Select_Reactor?select_reactor_two(g_unTwoMaxhandle,? 0 ,? 0 ,? 0 ,? 1 );
????ACE_Reactor * ?reactor_two? = ? new ?ACE_Reactor( & select_reactor_two);

????TestAcceptor?test_acceptor(reactor_one);
????test_acceptor.open( 1234 );

????TestAcceptor?test_acceptorw(reactor_two);
????test_acceptorw.open( 2345 );
????
????
????ACE_Thread_Manager::instance() -> spawn(event_loop_one,?reactor_one);
????ACE_Thread_Manager::instance() -> spawn(event_loop_two,?reactor_two);

???? return ?ACE_Thread_Manager::instance() -> wait();
}