muduo——EventLoop处理线程安全的问题

为了方便用户使用定时器接口,增加了几个函数,这几个函数都转而调用TimeQueue::addTimer(),这几个函数没有做特别的处理,是允许跨线程使用。

muduo——EventLoop处理线程安全的问题

这样一来会带来线程安全性方面的问题,muduo的解决方法不是加锁,而是把对TimeQueue的操作转移到IO线程来进行,EventLoop::runInLoop(const Functor& cb)函数,参数cb是回调函数,在它的IO线程执行某个用户任务回调,如果是在当前IO线程调用这个函数,调用会同步进行,如果用过在其他线程调用runInLoop(),cb会被加入队列,IO线程会被唤醒来调用Functor。muduo库中很多处理线程安全问题都是通过这个函数来处理的。

muduo——EventLoop处理线程安全的问题

由于IO线程平时阻塞在时间循环EventLoop::loop()的poll调用中,为了让IO线程能立即执行用户回掉,需要设法唤醒它。在libevent中处理信号的时候,用到了socket pair,将一端socket注册到libevent中管理,在注册信号函数的时候将它的处理函数自定义为libevent中已经写好的函数,这个函数中会向socket发消息,这样就会从阻塞的IO复用中返回。muduo在这里的处理也差不多使用这一的思路,不过muduo使用的是eventfd(2),可以更高效地唤醒,因为它不需要管理缓冲区。

muduo——EventLoop处理线程安全的问题

wakeup()就是向wakeupFd_中发消息,然后IO复用函数返回之后会调用handleRead()函数来处理, 然后EventLoop::loop()中就会调用doPendingFunctors()函数来处理,这个函数不是简单调用Functor,而是把回调列表swap()到局部变量functors中,这样一方面可以减小了临界区的长度(因为pendingFunctors_是暴露给其他线程的所以需要加锁,这样一来就不会阻塞其他线程调用queueInLoop()),另一方面也避免死锁(因为pendingFunctors_中的Functor可能再调用queueInLoop())。

muduo——EventLoop处理线程安全的问题

相关推荐