关于Reactor handle_events( ACE_Time_Value * max_wait_time )

我的 基于ACE的一个服务器通信程序，其中有以下一段代码：

ACE_THR_FUNC_RETURN threadFunc(void* arg)
{
 LOG_INIT();
 ACE_Time_Value timeout(5);
 ACE_Reactor * reactor=(ACE_Reactor*)arg;
 reactor->owner(ACE_OS::thr_self());
 while(SERVER_RUNNING)         
 {
     reactor->handle_events(timeout); 
 }
 return 0;
}

int ACE_TMAIN(int,ACE_TCHAR**)
{  
   .......  
   int reactorThreadGroupId=0;   
   reactorThreadGroupId=ACE_Thread_Manager::instance()->spawn_n(MAIN_REACTOR_THREAD_SIZE,threadFunc,ACE_Reactor::instance(),THR_NEW_LWP|THR_JOINABLE);
  if(reactorThreadGroupId==-1)
  {
    ACE_DEBUG((LM_INFO,ACE_TEXT("创建数据接收线程失败!")));
    return -1;
  }
  PRINT_INFO_LOG("数据接收模块启动成功!");
  ACE_Thread_Manager::instance()->wait_grp(reactorThreadGroupId);  
  //开始结束程序  
  .......
}

SERVER_RUNNING 是一个全局变量，主程序运行标志，当程序接收到Ctrl+C信号或者从CGI接口接收到Stop命令时，程序做安全关闭动作，等所有线程安全结束后在关闭主线程，而不是蛮横的直接关闭主线程。

在服务器上程序运行后，就开始觉得服务器很卡，使用TOP命令查看了下，发现该程序CPU占用率很高，可此时服务器并没有接收到多少数据处理，所以我断定程序可能出现了死循环之类的错误。再加入一些调试信息后，重新运行程序发现reactor->handle_events(timeout);只是第一次阻塞了5s，然后就不再阻塞，而是直接执行了下去，类似于死循环，耗去了大量CPU资源。翻看ACE源码文件，发现了对handle_event(ACE_Time_Value*)的如下注释：

This event loop driver blocks for up to <max_wait_time> before returning. It will return earlier if timer events,I/O events,window events,or signal events occur.

Note that <max_wait_time> can be 0,in which case this method blocks indefinitely until events occur.

<max_wait_time> is decremented to reflect how much time this call took. For instance,if a time value of 3 seconds is passed to handle_events and an event occurs after 2 seconds,<max_wait_time> will equal 1 second. This can be used if an application wishes to handle events for some fixed amount of time.

原来Reactor的时间循环会阻塞MAX_WAIT_TIME时间，等待有各种注册事件发生后返回。MAX_WAIT_TIME可设为0，如过为0，则程序会一直阻塞，直到有事件发生才返回。MAX_WAIT_TIME时间内会递减以反应这次调用耗费了多少时间，比如如果将MAX_WAIT_TIME设为3s，而2s后一个事件发生，那么MAX_WAIT_TIME值将会变为1s。

终于知道我程序的问题了，当程序第一次阻塞时，time_out是5s,但5s超时后，handle_event超时返回，而MAX_WAIT_TIME变为了0s，注意：MAX_WAIT_TIME是0s,并不是指这个参数为0，handle_event 阻塞时，0s超时，即不会阻塞，直接返回了，所以程序这里类似于一个死循环了,这也就导致了top命令下，该程序CPU占用率极高。

综上，程序修改如下：

ACE_THR_FUNC_RETURN threadFunc(void* arg)
{
LOG_INIT();
ACE_Time_Value timeout;
ACE_Reactor * reactor=(ACE_Reactor*)arg;
reactor->owner(ACE_OS::thr_self());
while(SERVER_RUNNING)
{
timeout.sec(5);
reactor->handle_events(timeout);
}
return 0;
}

ACE框架很强大，但里面有许许多多的细节问题，容易导致各种错误。这个时候，不要慌或者抱怨，去翻翻ACE手册或者源码文件，相信总能找到问题所在。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!