参照APG写的一个ACE_TP_Reactor服务程序

[asdf asdf]

参照APG写的一个ACE_TP_Reactor服务程序,上次没时间发，现补上。

_________________________________________________________________
与联机的朋友进行交流，请使用 MSN Messenger: http://messenger.msn.com/cn

[Stone Jiang]

楼主的实现非常复杂,
我给你一简单的版本 (主函数)

static ACE_THR_FUNC_RETURN event_loop (void *arg)
{
ACE_Reactor *reactor = static_cast<ACE_Reactor *> (arg);

reactor->owner (ACE_OS::thr_self ());
reactor->run_reactor_event_loop ();
return 0;
}

int ACE_TMAIN(int argc, TCHAR* argv[])
{

ACE::init();
int result = 0;

const size_t N_THREADS = 4;
ACE_TP_Reactor tp_reactor;
ACE_Reactor reactor (&tp_reactor);
auto_ptr<ACE_Reactor> delete_instance

ACE_Thread_Manager::instance ()->spawn_n
(N_THREADS, event_loop, ACE_Reactor::instance ());

ACE_Thread_Manager::instance ()->wait ();

ACE::fini();
return result;
}