//小弟在ACE reactor框架中开启一个定时器和一个接受器,代码如下:
class Timer: public ACE_Event_Handler
{
virtual int handle_timeout (const ACE_Time_Value ¤t_time,const void *act = 0);
}
int ACE_TMAIN(int argc,ACE_TCHAR *argv[])
{
Sgl_Timer::instance()->reactor(ACE_Reactor::instance());
Sgl_Timer::instance()->RegisterTimer(ACE_Time_Value(asDelay,0),ACE_Time_Value(beepIntval,0));
ACE_Acceptor _acceptor;
if( -1 == _acceptor.open(_addr) )
{
ACE_ERROR((LM_ERROR,"Acceptor open fail!\n"));
return -1;
}
return ACE_Reactor::instance()->run_reactor_event_loop(); //事件分发循环
}
小弟想在定时器中handle_timeout方法做WaitForSingleObject(hMutex,INFINITE);事件同步(阻塞等待),但这样好像_acceptor根本不能接收消息,它们是同一个线程吗?怎么破?各们大牛帮帮忙,谢谢啦!