ACE_Reactor(一)整体理解ACE_Reactor

前端之家收集整理的这篇文章主要介绍了ACE_Reactor(一)整体理解ACE_Reactor前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

ACE_Reactor框架的任务:

  • 检测来自于各种各样事件源的事件的发生
  • 将事件多路分离到他们的预先注册的事件处理器上
  • 将事件分派给由处理器所定义的挂钩方法,以按照应用程序所定义的方式来处理事件

ACE_Reactor类的实现。
接口声明放在Reactor.h中,
接口实现则分别放在Reactor.cpp和Reactor.ini文件中,而Reactor.inl作为内联函数直接在Reactor.h文件incliude了。
其实内部实现,主要还是封装了ACE_Reactor_Impl类中。

ACE_Reactor::notify方法
起到的作用是,可以打断多路复用监测事件的阻塞,让多路复用线程解除阻塞后重新检查需要监测的句柄和处理器集合,然后再去阻塞等待事件。
这一方法,可以似的其他线程能够唤醒反应器的拥有者线程,而该线程的事件多路分离器函数被阻塞并等待IO事件的发生。
为了防止一个事件处理器对应的事件在通知被分派前就失效了,引起分发无效事件,增加了purge_pending_notifications()方法,用于移除任何与来自于该队列的事件处理器相关联的通知

而在实际的ACE_Select_Reactor_Notify 类中,有如下指针说明:
/* 指向ACE_Select_Reactor的指针,如果该指针为空,那么Reactor管理器将不支持Notify事件
*/
ACE_Select_Reactor_Impl *select_reactor_;
又有一句这样的语句:

ACE_Reactor::run_reactor_event_loop方法
这个方法是用于处理事件的loop循环,除非里面的handle_events()调用返回-1。而handle_events是谁实现的呢,是本ACE_Reactor中封装的ACE_Reactor_Impl对象指针中的成员函数,而ACE_Reactor_Impl的具体对象由多种。handle_events的作用是直到超时时间到或者事件被触发才返回,其返回值是ACE_Event_Handlers派发(Dispatching)的总数。而altertable_handle_events和handle_events不同的地方在于,在eventloop会在系统将一个I/O完成例程或一个异步过程调用排队时返回。而这里所说的eventloop即run_reactor_event_loop的while(1)的loop循环。

再来看具体的实现:
在ACE_Dev_Poll_Reactor::handle_events

int ACE_Dev_Poll_Reactor::handle_events()
{
   return handle_events_i()
   {
       event_num=work_pending_i(){
            return epoll_wait();// or poll;
        }
        Dispatch(){
            dispatch_timer_handler(guard){
                timer_queue->expire_single
                }
            dispatch_io_event(guard){
                disp_mask=WIRTE/READ/EXCPET_MASK;
                callback=handle_output/input/exception;
                this->upcall(){
                    (event_handler->*callback)(handle)
                };//dispatch the detected event;
            }    


        }

   };

}

handle_events_i在其中调work_pending_i,这个函数中,若支持epoll则用epoll_wait去等待事件,否则用poll,返回值是检测到event数量。但是这里在事件分发处理时都是只处理第一个。
不管如何,这里可以看到其事件执行线程就是监测到事件的这个线程,那个线程调用ACE_Reactor::run_reactor_event_loop方法去等待并处理事件,那就是这个线程去完成事件处理。

ACE_Select_Reactor:使用select作为多路复用分离的函数
此时配合ACE_Pipe类实现ACE_Select_Reactor的消息通知机制,提供OS核内部传输数据的、可移植的双方向IPC机制。

ACE_TP_Reactor:在ACE_Select_Reactor基础上仍使用select作为多路复用分离的函数,扩展使用了领导者跟随者模型,将ACE_Select_Reactor事件扩展成一个线程池。

此时配合ACE_Pipe类实现ACE_Select_Reactor的消息通知机制,提供OS核内部传输数据的、可移植的双方向IPC机制。

相关参考书目: Pattern-Oriented Software Architecture Volume 1: A System of Patterns ebook PDF for free

猜你在找的React相关文章