现在的位置: 首页 > 综合 > 正文

Proactor和Reactor模式_继续并发系统设计的扫盲

2017年11月02日 ⁄ 综合 ⁄ 共 2418字 ⁄ 字号 评论关闭

Proactor和Reactor模式_继续并发系统设计的扫盲

6.6.2008

Kevin Lynx

Proactor和Reactor都是并发编程中的设计模式。在我看来,他们都是用于派发/分离IO操作事件的。这里所谓的
IO事件也就是诸如read/write的IO操作。"派发/分离"就是将单独的IO事件通知到上层模块。两个模式不同的地方
在于,Proactor用于异步IO,而Reactor用于同步IO。

摘抄一些关键的东西:

"
Two>///
class handler
{
public:
    virtual void onRead() = 0;
    virtual void onWrite() = 0;
    virtual void onAccept() = 0;
}


class dispatch
{
public:
    void poll()
    {
        // add fd in the set.
        
//
        
// poll every fd
        int c = select( 0, &read_fd, &write_fd, 0, 0 );
        if( c > 0 )
        {
            for each fd in the read_fd_set
            {    if fd can read
                    _handler->onRead();
                if fd can accept
                    _handler->onAccept();
            }
 

            for each fd in the write_fd_set
            {
                if fd can write
                    _handler->onWrite();
            }

        }

    }
 

    void setHandler( handler *_h )
    {
        _handler = _h;
    }
 

private:
    handler *_handler;
}


/// application
class MyHandler : public handler
{
public:
    void onRead()
    {
    }
 

    void onWrite()
    {
    }
 

    void onAccept()
    {
    }

}



在网上找了份Proactor模式比较正式的文档,其给出了一个总体的UML类图,比较全面:

根据这份图我随便写了个例子代码:

class AsyIOProcessor
{
public:
    void do_read()
    {
        //send read operation to OS
        
// read io finished.and dispatch notification
        _proactor->dispatch_read();
    }
 

private:
    Proactor *_proactor;
}


class Proactor
{
public:
    void dispatch_read()
    {
        _handlerMgr->onRead();
    }
 

private:
    HandlerManager *_handlerMgr;
}


class HandlerManager
{
public:
    typedef std::list<Handler*> HandlerList; 

public:
    void onRead()
    {
        // notify all the handlers.
        std::for_each( _handlers.begin(), _handlers.end(), onRead );
    }
 

private:
    HandlerList *_handlers;
}


class Handler
{
public:
    virtual void onRead() = 0;
}


// application level handler.
class MyHandler : public Handler
{
public:
    void onRead() 
    {
        // 
    }

}



Reactor通过某种变形,可以将其改装为Proactor,在某些不支持异步IO的系统上,也可以隐藏底层的实现,利于编写跨平台
代码。我们只需要在dispatch(也就是demultiplexor)中封装同步IO操作的代码,在上层,用户提交自己的缓冲区到这一层,
这一层检查到设备可操作时,不像原来立即回调handler,而是开始IO操作,然后将操作结果放到用户缓冲区(读),然后再
回调handler。这样,对于上层handler而言,就像是proactor一样。详细技法参见这篇文章

其实就设计模式而言,我个人觉得某个模式其实是没有完全固定的结构的。不能说某个模式里就肯定会有某个类,类之间的
关系就肯定是这样。在实际写程序过程中也很少去特别地实现某个模式,只能说模式会给你更多更好的架构方案。

最近在看spserver的代码,看到别人提各种并发系统中的模式,有点眼红,于是才来扫扫盲。知道什么是leader>

posted on 2008-06-06 13:25 Kevin Lynx 阅读(20572) 评论(7)  编辑 收藏 引用 所属分类: network 、模块架构

抱歉!评论已关闭.