? ? ? ? ??EventLoopThreadPool是IO線程對應的線程池，通過調(diào)用start函數(shù)來new EventLoopThread創(chuàng)建對應的線程和其loop,并將創(chuàng)建的保存在vector中。創(chuàng)建TcpConnection時，就會從EventLoopThreadPool中獲取一個IO線程。

EventLoopThreadPool.h

// Copyright 2010, Shuo Chen. All rights reserved. // http://code.google.com/p/muduo/ // // Use of this source code is governed by a BSD-style license // that can be found in the License file.// Author: Shuo Chen (chenshuo at chenshuo dot com) // // This is an internal header file, you should not include this.#ifndef MUDUO_NET_EVENTLOOPTHREADPOOL_H #define MUDUO_NET_EVENTLOOPTHREADPOOL_H#include "muduo/base/noncopyable.h" #include "muduo/base/Types.h"#include <functional> #include <memory> #include <vector>namespace muduo {namespace net {class EventLoop; class EventLoopThread;class EventLoopThreadPool : noncopyable {public:typedef std::function<void(EventLoop*)> ThreadInitCallback;EventLoopThreadPool(EventLoop* baseLoop, const string& nameArg);~EventLoopThreadPool();void setThreadNum(int numThreads) { numThreads_ = numThreads; }void start(const ThreadInitCallback& cb = ThreadInitCallback());// valid after calling start()/// round-robinEventLoop* getNextLoop();/// with the same hash code, it will always return the same EventLoopEventLoop* getLoopForHash(size_t hashCode);std::vector<EventLoop*> getAllLoops();bool started() const{ return started_; }const string& name() const{ return name_; }private:EventLoop* baseLoop_; //主線程的事件驅(qū)動循環(huán)，TcpServer所在的事件驅(qū)動循環(huán)，創(chuàng)建TcpServer傳入的EventLoopstring name_;bool started_;int numThreads_; //線程數(shù) int next_; //標記下次應該取出哪個線程，采用round_robinstd::vector<std::unique_ptr<EventLoopThread>> threads_; //線程池中所有的線程 //線程池中每個線程對應的事件驅(qū)動循環(huán)，從線程池取出線程實際上返回的是事件驅(qū)動循環(huán)//每個事件驅(qū)動循環(huán)運行在一個線程中std::vector<EventLoop*> loops_; };} // namespace net } // namespace muduo#endif // MUDUO_NET_EVENTLOOPTHREADPOOL_H

EventLoopThreadPool.cc

// Copyright 2010, Shuo Chen. All rights reserved. // http://code.google.com/p/muduo/ // // Use of this source code is governed by a BSD-style license // that can be found in the License file.// Author: Shuo Chen (chenshuo at chenshuo dot com)#include "muduo/net/EventLoopThreadPool.h"#include "muduo/net/EventLoop.h" #include "muduo/net/EventLoopThread.h"#include <stdio.h>using namespace muduo; using namespace muduo::net;//EventLoopThreadPool loop對應的線程池 EventLoopThreadPool::EventLoopThreadPool(EventLoop* baseLoop, const string& nameArg): baseLoop_(baseLoop),name_(nameArg),started_(false),numThreads_(0),next_(0) { }EventLoopThreadPool::~EventLoopThreadPool() {// Don't delete loop, it's stack variable }void EventLoopThreadPool::start(const ThreadInitCallback& cb) //開啟線程池，創(chuàng)建線程 {assert(!started_);baseLoop_->assertInLoopThread();started_ = true;for (int i = 0; i < numThreads_; ++i){char buf[name_.size() + 32];snprintf(buf, sizeof buf, "%s%d", name_.c_str(), i);EventLoopThread* t = new EventLoopThread(cb, buf);threads_.push_back(std::unique_ptr<EventLoopThread>(t));loops_.push_back(t->startLoop());}if (numThreads_ == 0 && cb){cb(baseLoop_);} }EventLoop* EventLoopThreadPool::getNextLoop() //獲取一個線程（事件驅(qū)動循環(huán)），通常在創(chuàng)建TcpConnection時調(diào)用 {baseLoop_->assertInLoopThread();assert(started_);EventLoop* loop = baseLoop_;if (!loops_.empty()){// round-robinloop = loops_[next_];++next_;if (implicit_cast<size_t>(next_) >= loops_.size()){next_ = 0;}}return loop; }EventLoop* EventLoopThreadPool::getLoopForHash(size_t hashCode) {baseLoop_->assertInLoopThread();EventLoop* loop = baseLoop_;if (!loops_.empty()){loop = loops_[hashCode % loops_.size()];}return loop; }std::vector<EventLoop*> EventLoopThreadPool::getAllLoops() {baseLoop_->assertInLoopThread();assert(started_);if (loops_.empty()){return std::vector<EventLoop*>(1, baseLoop_);}else{return loops_;} }

?

總結

以上是生活随笔為你收集整理的muduo之EventLoopThreadPool的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。