`
sjk2013
  • 浏览: 2177500 次
文章分类
社区版块
存档分类
最新评论

ACE_Task自然退出的问题

 
阅读更多

最近解决了以前遗留的ACE问题(原来的应用退出时实际上各子线程不是自然退出,而是因为进程终止而强制退出的),高兴!特此记录一下。

我们的应用使用反应器框架模式,反应器框架通过任务的消息队列和具体处理任务解耦,任务(继承自ACE_Task)线程通过getq获取消息内容并处理。

原来的程序类似于下面:

int My_Task::open(void* args)
{
activate(THR_NEW_LWP | THR_JOINABLE, 5, 1);//打开5个工作者线程
return 0;
}

int My_Task::svc()
{
while ( 0==m_nEnd ) //m_nEnd结束标记,为1时退出线程
{
ACE_Message_Block *mb =0;
try{

getq(mb);

...
}
}
}


实际上即使有设置结束标记,上面的办法也不能自然退出,因为并不是每个任务工作者线程getq都有结果(有的处于饥饿状态,就会一直阻塞在getq上,造成不能自然退出)。
可以这样改下:

//任务有很多,所以写成宏方便调用,主要是为getq设置1秒超时
#define MY_GETQ(X) /
ACE_Time_Value tvTmp = ACE_OS::gettimeofday ();/
tvTmp += ACE_Time_Value(1);/
getq(X, &tvTmp);/
if (X == NULL)/
continue;

...

int My_Task::svc()
{
while ( 0==m_nEnd ) //m_nEnd结束标记
{
ACE_Message_Block *mb =0;
try{

MY_GETQ(mb);

...
}
}
}


再查看了一下ACE例程,发现有的用了超时的办法,有的用这个来判断是否退出:
virtual int svc (void)
{
while (1)
{
ACE_Message_Block *mb = NULL;
if (this->getq (mb) == -1)
{
ACE_DEBUG ((LM_INFO,
ACE_TEXT ("(%t) Shutting down/n")));
break;
}

// Process the message.
process_message (mb);
}

return 0;
}

不过就有一个问题,什么情况下getq会返回-1 ?

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics