一、模块划分与职责
| 模块 | 作用 |
|---|---|
Any | 类型擦除容器，用于存储任务返回的任意类型值，支持安全类型转换。 |
Semaphore | 基于mutex+condition_variable实现的计数信号量，用于线程间同步。 |
Task | 任务抽象基类，用户继承并实现run()，通过exec()触发执行并设置结果。 |
Result | 任务返回值载体，内部含信号量，用户调用get()阻塞等待结果到达。 |
Thread | 轻量线程封装，存储线程函数和自增ID，启动时detach分离。 |
ThreadPool | 核心管理类：任务队列、线程池、模式切换、动态扩缩容、生命周期控制。 |
二、核心机制详解
1. 生产者-消费者模型
生产者：用户调用
submitTask将任务shared_ptr<Task>放入任务队列。消费者：池内所有线程运行
threadFunc，循环从队列中取任务执行。线程安全：任务队列由
taskQueMtx_互斥锁保护，配合notEmpty_和notFull_条件变量实现阻塞/通知。
2. 两种工作模式
MODE_FIXED（固定模式）
线程数量在start()时确定，永不增减。任务队列满时提交者阻塞（最长1秒）。MODE_CACHED（缓存模式）动态扩容：当
taskSize_ > idleThreadSize_且当前线程数未达上限时，立即创建新线程。空闲回收：线程在无任务时使用
wait_for超时等待，若空闲超过THREAD_MAX_IDLE_TIME（60秒）且当前线程数 > 初始线程数，则线程自我销毁（从threads_中删除并退出）。
3. 异步结果获取
每个任务提交时返回一个
Result对象，内部持有指向该任务的shared_ptr和一个信号量。任务执行完时，
Task::exec()调用run()得到Any返回值，再通过Result::setVal存储并post信号量。用户线程调用
Result::get()会wait信号量，直到结果就绪。
4. 线程生命周期管理
启动：
start(initThreadSize)创建Thread对象，每个对象启动时detach分离线程，线程函数绑定到ThreadPool::threadFunc。正常退出：析构函数设置
isPoolRunning_ = false，唤醒所有等待线程，每个线程检测到标志后从threads_中删除自身，最后通知exitCond_，主线程等待所有线程退出。缓存模式主动回收：空闲超时的线程直接
return，同样会执行threads_.erase(threadid)并修改计数。
5. 任务队列的背压控制
提交任务时，最多等待1秒直到队列有空间（
notFull_.wait_for），否则返回无效Result（isValid_=false）。取出任务后，若队列仍非空，则通知其他线程继续取任务；同时通知
notFull_，让可能阻塞的生产者继续提交。
三、设计亮点与权衡
类型擦除的返回值：
Any类通过多态 + 模板派生，避免了void*的不安全性，用户获取时需显式指定类型（cast_<T>()），若类型不匹配则抛异常。信号量自实现：C++11 标准库无信号量，用
mutex+condition_variable封装了一个简洁的Semaphore，用于Result中实现单次同步。线程ID的自定义映射：每个
Thread有自增整型ID，线程池用unordered_map<int, unique_ptr<Thread>>存储，线程函数通过传入的threadid参数在退出时删除自身条目。
注意：这里依赖“线程函数参数就是 map 的 key”这一约定，且删除操作在持有锁时进行，避免了并发问题。原子操作与锁的精细使用：
taskSize_、curThreadSize_、idleThreadSize_使用atomic_int减少锁竞争；但任务队列的操作仍必须加锁，以保证条件变量的正确性。资源回收的同步：析构时使用
exitCond_等待所有线程退出，避免detach后主线程退出导致进程 crash。每个线程退出前都会notify_all，确保主线程被唤醒。可扩展性：用户只需继承
Task并实现run()，即可定义任意业务逻辑，线程池只负责调度和结果传递。
问题一:如果把线程池的任务队列从 std::shared_ptr<Task> 改成裸指针 std::queue<Task*>会怎么样
void someFunction() { MyTask task; // 栈上的临时对象 pool.submitTask(&task); // 传入裸指针 } // 函数结束，task 被销毁线程池内部将
&task存入std::queue<Task*>。someFunction执行完毕后，task对象生命周期结束，内存被回收（或栈空间被复用）。队列中只剩下一个指向已销毁对象的指针。
void someFunction() { auto sp = std::make_shared<MyTask>(); // 堆对象，引用计数 = 1 pool.submitTask(sp); // 传入 sp（左值，拷贝） } // someFunction 结束，sp 销毁，引用计数减 1（但队列中还有一份，对象不销毁）在拷贝的时候计数器会加1,所以不用担心对象会销毁
问题二:为什么要自己封装一个Thread类呢
封装Thread类的根本原因是：给系统线程附加一个整数 ID，以便在线程池中高效地标识、管理和回收特定线程。
具体来说，std::thread本身不提供直接可用的整数标识符，其get_id()返回的std::thread::id是一个不透明的结构体，不能直接作为unordered_map的键（需要特化hash），也无法方便地打印为整数用于日志或调试。
通过自定义Thread类，作者实现了：
自增整数 ID：
static int generateId_确保每个线程获得一个唯一的整数 ID，可以直接作为unordered_map<int, unique_ptr<Thread>>的键。ID 传递到线程函数：启动
std::thread时，将整数 ID 作为参数传递给线程函数（threadFunc(int threadid)），这样线程函数就能知道自己是谁，从而在需要退出时安全地调用threads_.erase(threadid)删除自身。封装
detach行为：让线程池无需显式管理每个线程的join，简化生命周期控制。
如果不封装，直接用vector<std::thread>，线程函数就无法获得一个简单的整数索引来从容器中删除自己，管理起来会复杂且低效。因此，封装Thread是一种轻量级、实用的设计模式。
问题三:把线程函数写进Thread会带来的问题
如果Thread内部直接写死任务循环逻辑，那么Thread就必须知道任务队列、互斥锁、条件变量、线程池模式等细节。这意味着Thread无法脱离ThreadPool独立使用，也失去了复用性。
问题四:为什么要绑定
Thread类想要调用ThreadPool类的成员函数threadFunc，但成员函数必须通过某个ThreadPool对象来调用（需要this指针），而Thread的接口只接受一个参数为int的普通函数对象。通过std::bind（或 lambda）将this绑定进去，生成一个符合void(int)签名的新可调用对象，就能让Thread在启动时传入整数 ID，正确调用到对应线程池实例的成员函数。
如果不绑定，直接传递成员函数指针，类型不匹配，编译会失败。
给包装器类别起个别名
问题五:为什么分离线程
t是临时变量, 分离线程后，即使对象t被销毁, 线程也会独立在后台运行，直到它执行的函数（func_）返回。
上边三行的写法相当于下面一行的写法
问题:怎么设计run函数的返回值,可以表示任意的类型
问题:如何设计Result机制呢
用c++知识,构建一个Any类型
基类指针指向派生类+模板
构建一个信号量类
互斥锁加条件变量
