学习笔记：用于事件多路分离和分派的reactor体系结构模式

        如上图所示&＃xff0c;应答者&＃xff08;或称反应器&＃xff09;框架通过在OS事件多路分离接口上进行监听&＃xff0c;检测事件的发生。当检测到事件的发生后&＃xff0c;回调预登记时间处理器&＃xff08;event handler&＃xff09;对象中的方法。该方法是一个回调函数&＃xff0c;包含有应用处理事件的具体代码&＃xff0c;由应用程序开发者实现。

       于是&＃xff0c;应用开发者必须做好以下工作&＃xff1a;

      &＃xff08;1&＃xff09;创建事件处理器对象&＃xff0c;以便将来能处理它所感兴趣的事件&＃xff1b;

      &＃xff08;2&＃xff09;向反应器&＃xff08;reactor,应答者&＃xff09;注册、登记&＃xff0c;并告知反应器处理该事件的事件处理器的指针。

     这样&＃xff0c;随后&＃xff0c;反应器框架就能自动地完成以下工作&＃xff1a;

      &＃xff08;1&＃xff09;在内部维护一个表&＃xff08;结构体表或者哈希表等等&＃xff09;&＃xff0c;将不同的事件类型与事件处理器对象联系起来&＃xff1b;

       &＃xff08;2&＃xff09;当用户&＃xff08;即应用开发者&＃xff09;已登记的某个事件发生时&＃xff0c;反应器检测到事件发生&＃xff0c;回调处理器中相应callback函数。

       下面我们看一个例子&＃xff1a;

#include
#include "ace/Reactor.h"
#include "ace/Event_handler.h"
class MyEventHandler:public ACE_EVENT_HANDLER
{
   int handle_signal( int signum, siginfo_t *, ucontext_t * )
   {
      case SIGWINCH:
           printf("We are handling SIGWINCH.\n");
           break;
      case SIGINT:
            printf("We are handling SIGWINCH.\n");
            break;
       default:
            break;
       return 0;
         
   }
  
}

int main( int argc, char *argv[] )
{
    MyEventHandler *HandleEventObject &＃61; new MyEventHandler;
    ACE_Reactor::Instance()->register_handler(SIGWINCH,HandleEventObject);
    ACE_Reactor::Instance()->register_handler(SIGINT, HandleEventObject);
    while(1)
    {
        ACE_Reactor::instance()->handle_events();
    }
}