Method setWorkersCount

aui.core/src/AUI/Thread/AThreadPool.cpp:161–179

}

void AThreadPool::setWorkersCount(std::size_t workersCount) {
    AUI_ASSERTX(workersCount >= 2 && workersCount <= 1000, "invalid worker count");
    std::unique_lock lck(mQueueLock);
    if (mWorkers.size() >= workersCount) {
        while (mWorkers.size() > workersCount) {
            mCV.notify_all();
            mWorkers.last()->aboutToDelete();
            lck.unlock();
            mWorkers.pop_back();
            lck.lock();
        }
    } else {
        // have to add new workers
        mWorkers.reserve(workersCount);
        while (mWorkers.size() < workersCount) {
            mWorkers.push_back(std::make_unique<Worker>(*this, mWorkers.size()));
        }
    }
}

size_t AThreadPool::getPendingTaskCount() { return mQueueHighest.size() + mQueueLowest.size() + mQueueMedium.size(); }