使用ACE_Task消息对列,从消息对列中获取消息时产生死循环

peakzhang

我使用的是ACE5.5版本，使用以静态连接库Unicode编码的方式使用
代码如下

2. int CProtocolProcessTask::svc()
3. {
4.     ACE_Thread_Manager *mgr = this->thr_mgr();
5.     ACE_ASSERT(mgr != NULL);
6.     while(1)
7.     {
8.         //该服务被取消
9.         if(mgr->testcancel(mgr->thr_self()))
10.             return 0;
12.         ACE_Message_Block *mb = NULL;
13.         ACE_Time_Value tv(5);
14.         int iRet = this->getq(mb,&tv);
15.         if(iRet == -1 && errno == EWOULDBLOCK)
16.             continue;
17.         else
18.         {
19.             if(mb)
20.             {
21.                 //协议逻辑入口
22.                 ProtocolProcessMessage(mb);
23.                 mb->release();
24.             }
25.         }
26.     }
27.     return 0;
28. }

复制代码

主要是这两句话
       ACE_Time_Value tv(5);
        int iRet = this->getq(mb,&tv);
我设置的是5秒中的等待，可是this->getq(mb,&tv);从来不会等待进入iRet == -1 && errno == EWOULDBLOCK逻辑
我使用NULL会阻塞,不管tv(xx)中的数值有多大都会是这样，请高手给于解答,万分感谢

peakzhang

ACE_Time_Value tv(5);
        int iRet = this->getq(mb,&tv);

你这里指定的相对时间,应该是绝对时间吧?你测试看看,我这里没编译器,也没有ACE代码..

ACE_Time_Value out_(xxx);有个获取时间的函数忘了,你找找看..

out_+=tv;

this->getq(mb,&out_);