Method wait

external/nvImageCodec/src/thread_pool.cpp:122–141

    }

    void ThreadPool::wait(bool checkForErrors) {
        std::unique_lock<std::mutex> lock(mutex_);
        if (!started_)
            return;
        completed_.wait(lock, [this] { return this->work_complete_; });
        started_ = false;
        if (checkForErrors) {
            // Check for errors
            for (size_t i = 0; i < threads_.size(); ++i) {
                if (!tl_errors_[i].empty()) {
                    // Throw the first error that occurred
                    std::stringstream ss;
                    ss << "Error in thread " << i << ": " << tl_errors_[i].front();
                    std::string error = ss.str();
                    tl_errors_[i].pop();
                    throw std::runtime_error(error);
                }
            }
        }
    }

    int ThreadPool::getThreadsNum() const {
        return threads_.size();