bool OBSThreadPool::init(size_t num) { std::unique_lock lock(_mutex); if (!_threads.empty()) { return false; } _threadNum = num; return true; } void OBSThreadPo...-Go服务器开发

要添加一个modify方法来修改线程池中线程的个数，需要做以下几个步骤：

在OBSThreadPool类中声明modify方法。
实现modify方法，在该方法内部根据传入的新线程数与当前线程数的大小关系来进行线程数量的调整。
在调用 start() 方法时检查是否存在已有线程，并且在 run() 方法中适当地处理新增或减少的线程。

下面是对上述步骤的简要代码示例：

void OBSThreadPool::modify(size_t newNum)
{
    std::unique_lock<std::mutex> lock(_mutex);
    if (newNum == _threadNum) {
        return;  // 如果新旧线程数量相同，则直接返回
    }
    if (newNum < _threadNum) {
        size_t diff = _threadNum - newNum;
        for (size_t i = 0; i < diff; ++i) {
            _tasks.push_back(nullptr); // 添加空任务以退出多余线程
            _condition.notify_one();   // 通知等待的线程处理退出信号
        }
    } else {
        size_t diff = newNum - _threadNum;
        for (size_t i = 0; i < diff; ++i) {
            _threads.push_back(new thread(&OBSThreadPool::run, this));
        }
    }
    _threadNum = newNum;
}
// 修改start方法，确保每次调用start都会重新创建指定数量的工作线程
bool OBSThreadPool::start()
{
    std::unique_lock<std::mutex> lock(_mutex);
    for (size_t i = 0; i < _threadNum; i++)
    {
        _threads.push_back(new thread(&OBSThreadPool::run, this));
    }
    
	// 清除可能存在于之前执行stop时未清理干净的无效数据
	_tasks.clear();
	
	return true;
}