ACE框架reactor同步问题求助?

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

{
virtual int handle_timeout (const ACE_Time_Value &current_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根本不能接收消息,它们是同一个线程吗?怎么破?各们大牛帮帮忙,谢谢啦!

1个回答

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

u013572569
andy当我遇上你 http://blog.csdn.net/zhdaniel/article/details/850888这里说ACE_TP_Reactor支持多线程并发运行
4 年多之前 回复
u013572569
andy当我遇上你 嗯,oyljerry,你说的对,我想再加入一个reactor用于处理定时器IO处理,可以行得通吗?
4 年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问