实例：一个服务器程序的架构介绍

当任务产生时，只要我们将执行任务的函数 push_back 到 m_functors 这个 stl::vector 对象中即可。但是问题来了，如果是其他线程产生的任务，两个线程同时操作 m_functors，必然要加锁，这也会影响效率。muduo 是这样做的：

void add_task(const Functor& cb)   
{   
    std::unique_lock<std::mutex> lock(mutex_);   
    m_functors.push_back(cb);      
}   
 
void do_task()   
{   
    std::vector<Functor> functors;   
    {   
        std::unique_lock<std::mutex> lock(mutex_);   
        functors.swap(m_functors);   
    }   
 
    for (size_t i = 0; i < functors.size(); ++i)   
    {   
        functors[i]();   
    }   
} 

看到没有，利用一个栈变量 functors 将 m_functors 中的任务函数指针倒换(swap)过来了，这样大大减小了对 m_functors 操作时的加锁粒度。前后变化：变化前，相当于原来 A 给 B 多少东西，B 消耗多少，A 给的时候，B 不能消耗;B 消耗的时候A不能给。现在变成A将东西放到篮子里面去，B 从篮子里面拿，B 如果拿去一部分后，只有消耗完了才会来拿，或者 A 通知 B 去篮子里面拿，而 B 忙碌时，A 是不会通知 B 来拿，这个时候 A 只管将东西放在篮子里面就可以了。

bool bBusy = false;   
void add_task(const Functor& cb)   
{   
    std::unique_lock<std::mutex> lock(mutex_);   
    m_functors_.push_back(cb);   
 
    //B不忙碌时只管往篮子里面加，不要通知B   
    if (!bBusy)   
    {   
        wakeup_to_do_task();   
    }   
}   
 
void do_task()   
{   
    bBusy = true;   
    std::vector<Functor> functors;   
    {   
        std::unique_lock<std::mutex> lock(mutex_);   
        functors.swap(pendingFunctors_);   
    }   
 
    for (size_t i = 0; i < functors.size(); ++i)   
    {   
        functors[i]();   
    }   
 
    bBusy = false;   
} 

看，多巧妙的做法!

（编辑：衡阳站长网）

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