muduo库如何支持多线程
EventLoopThread（IO线程类）
EventLoopThreadPool（IO线程池类）
IO线程池的功能是开启若干个IO线程，并让这些IO线程处于事件循环的状态
下面的这些代码可能和前面给出的源代码有些不一样，阅读的同学请注意了
EventLoopThreadPool头文件
eventloopthreadpool.h
[cpp
// 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/Condition.h>
#include <muduo/base/Mutex.h>
#include <vector>
#include <boost/function.hpp>
#include <boost/noncopyable.hpp>
#include <boost/ptr_container/ptr_vector.hpp>
namespace muduo
{
namespace net
{
class EventLoop;
class EventLoopThread;
class EventLoopThreadPool : boost::noncopyable
{
public:
typedef boost::function<void（EventLoop*）> ThreadInitCallback;
EventLoopThreadPool（EventLoop* baseLoop）；
~EventLoopThreadPool（）；
void setThreadNum（int numThreads） { numThreads_ = numThreads; }
void start（const ThreadInitCallback& cb = ThreadInitCallback（））；
EventLoop* getNextLoop（）；
private:
EventLoop* baseLoop_; // 与Acceptor所属EventLoop相同
bool started_; /*是否启动*/
int numThreads_; // 线程数
int next_; // 新连接到来，所选择的EventLoop对象下标
boost::ptr_vector<EventLoopThread> threads_; // IO线程列表
std::vector<EventLoop*> loops_; // EventLoop列表
};
}
}
#endif // MUDUO_NET_EVENTLOOPTHREADPOOL_H
EventLoopThreadPool源文件
eventloopthreadpool.cc
[cpp]
// 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 <boost/bind.hpp>
using namespace muduo;
using namespace muduo::net;
EventLoopThreadPool::EventLoopThreadPool（EventLoop* baseLoop）
: baseLoop_（baseLoop）， // 与Acceptor所属EventLoop相同
started_（false），
numThreads_（0），
next_（0）
{
}
EventLoopThreadPool::~EventLoopThreadPool（）
{
// Don't delete loop, it's stack variable
}