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

为了实现修改线程池中线程的个数和使每个线程都能独立控制是否退出，您需要对代码进行一些修改。下面是一个可能的解决方案：

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;
}
void OBSThreadPool::stop()
{
    std::unique_lock<std::mutex> lock(_mutex);
    for(auto& thread : _threads)
    {
        if(thread->joinable())
        {
            thread->join();
        }
        delete thread;
    }
    
	_threads.clear();
	_bTerminate = true;
}
bool OBSThreadPool::isTerminate(size_t index)
{
    std::unique_lock<std::mutex> lock(_terminateMutex);
    
	if(index >= 0 && index <_threads.size()){
		return terminateFlags[index];
	}
	
	return false;
}
void OBSThreadPool::setTerminate(size_t index, bool value)
{
	std::unique_lock<std::mutex> lock(_terminateMutex);
	
	if(index >= 0 && index <_threads.size()){
		terminateFlags[index] = value;
	}
}