| 236 | // |
| 237 | // |
| 238 | Size addThreads(Size nThreadsCount) |
| 239 | { |
| 240 | std::scoped_lock lock(m_mtxThreads); |
| 241 | if (m_fStop) |
| 242 | error::InvalidUsage(FMT("The pool is being stopped <" << m_sName << ">")).throwException(); |
| 243 | for (Size n = 0; n < nThreadsCount; ++n) |
| 244 | m_threads.push_back(std::thread(&Impl::startPoolThread, this)); |
| 245 | return m_threads.size(); |
| 246 | } |
| 247 | |
| 248 | // |
| 249 | // |
nothing calls this directly
no test coverage detected