EventLoopThreadPool.h

#pragma onec
#include "noncopyable.h"
#include<functional>
#include<string>
#include<vector>
#include<memory>
class EventLoop;
class EventLoopThread;

class EventLoopThreadPool :noncopyable{

public:
    using ThreadInitCallback = std::function<void(EventLoop*)>;
    EventLoopThreadPool(EventLoop *baseLoop, const std::string &nameArg);
    ~EventLoopThreadPool();

    void setThreadNum(int numThreads){numThreads = numThreads;}

    void start(const ThreadInitCallback &cb = ThreadInitCallback());
    EventLoop* getNextLoop();
    std::vector<EventLoop*> getAllLoops();

    bool started()const{return started_;}
private:
    EventLoop *baseLoop_;
    std::string name_;
    bool started_;
    int numThreads_;
    int next_;
    std::vector<std::unique_ptr<EventLoopThread>> threads_;
    std::vector<EventLoop*> loops_;
};