#pragma once
#include <pthread.h>
#include <list>
#include "locker.h"

// 文件名称：threadpool.h
// 类：threadpool
// 功能：线程池
// 作者：TRF

// 线程池类，模板类，方便复用
template <typename T>
class Threadpool
{
private:
    int m_thread_num;               // 线程数量
    pthread_t *m_threads;           // 线程池数组，大小为m_thread_num
    int m_max_requeats;             // 请求队列中最多允许的，等待处理的请求数量
    std::list<T *> m_workqueue;     // 请求队列，存放待处理的请求
    Locker m_queuelocker;           // 互斥锁
    Semaphore m_queuestat;          // 信号量，用来判断是否有任务需要处理
    bool m_stop;                    // 是否结束线程
    static void *worker(void *arg); // 线程函数，static只能在本文件中定义，不能放在类外面
    void run();                     // 运行线程池
public:
    Threadpool(int thread_num = 8, int max_requeats = 100000);
    ~Threadpool();
    bool append(T *request); // 添加任务到请求队列
};