EventLoopThreadPool.h

#pragma once

#include "nocopyable.h"
#include <functional>
#include <string>
#include <vector>
#include <memory>

class EventLoop;
class EventLoopThread;


class EventLoopThreadPool{
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()); 

    /* 如果工作在多线程中，baseloop 默认以轮询的方式分配channel给subloop  */
    EventLoop* getNextloop();

    std::vector<EventLoop*> getAllloops();

    bool started() const { return started_; }

    const std::string& name() const {return name_;}

private:
    EventLoop* baseLoop_;    /* Eventloop */
    std::string name_;        
    bool started_;
    int numThreads_;
    int next_;
    std::vector<std::unique_ptr<EventLoopThread>> threads_;
    std::vector<EventLoop*> loops_;
};