//
// Created by 22100 on 2024/5/13.
//

#ifndef REACTORHTTPCPP_THREADPOOL_H
#define REACTORHTTPCPP_THREADPOOL_H
#include "EventLoop.h"
#include <vector>
#include "WorkerThread.h"


class ThreadPool {
public:
    ThreadPool(EventLoop* eventLoop, int count);
    ~ThreadPool();

    void run(); // 启动线程池
    EventLoop* takeWorkerEventLoop(); // 取出线程池中某个子线程反应堆实例
private:
    EventLoop* m_mainLoop; // 主线程反应堆模型
    bool m_isStart;
    int m_threadNum;
    std::vector<WorkerThread*> m_workerThreads;
    int m_index;
};


#endif //REACTORHTTPCPP_THREADPOOL_H