问题描述

ACE框架reactor同步问题求助?

//小弟在ACE reactor框架中开启一个定时器和一个接受器，代码如下：
class Timer: public ACE_Event_Handler

{
virtual int handle_timeout (const ACE_Time_Value &current_timeconst void *act = 0);
}

int ACE_TMAIN(int argcACE_TCHAR *argv[])
{

Sgl_Timer::instance()->reactor(ACE_Reactor::instance());
Sgl_Timer::instance()->RegisterTimer(ACE_Time_Value(asDelay0)ACE_Time_Value(beepIntval0));
ACE_Acceptor _acceptor;
if( -1 == _acceptor.open(_addr) )

{
ACE_ERROR((LM_ERRORAcceptor open fail!
""));
return -1;
}

return ACE_Reactor::instance()->run_reactor_event_loop(); //事件分发循环
}

小弟想在定时器中handle_timeout方法做WaitForSingleObject(hMutexINFINITE);事件同步(阻塞等待)，但这样好像_acceptor根本不能接收消息，它们是同一个线程吗？怎么破？各们大牛帮帮忙，谢谢啦！

解决方案

handle_timeout 阻塞会阻塞整个定时器，你如果要等待，应该是其他地方等待，或者开一个线程来专门等待hMutex，然后事件触发了，再做你的工作。
定时器等让它们一直运行。

解决方案二：
使用ACE Reactor框架编程
使用ACE Reactor框架编程