Searched refs:workerCtrl (Results 1 – 2 of 2) sorted by relevance
99 workerCtrl.lock.lock(); in SetWorkerMaxNum()112 workerCtrl.lock.unlock(); in SetWorkerMaxNum()175 workerCtrl.lock.lock(); in TotalCount()176 int total = workerCtrl.sleepingWorkerNum + workerCtrl.executionNum; in TotalCount()247 totalWorker += workerCtrl.executionNum + workerCtrl.sleepingWorkerNum; in IsExceedDeepSleepThreshold()255 workerCtrl.lock.lock(); in Poke()260 if (workerCtrl.executionNum >= workerCtrl.maxConcurrency) { in Poke()309 workerCtrl.lock.lock(); in NotifyWorkers()312 (workerCtrl.executionNum + workerCtrl.sleepingWorkerNum); in NotifyWorkers()377 notifyType, workerCtrl.executionNum, workerCtrl.maxConcurrency, in HandleTaskNotifyConservative()[all …]
21 WorkerCtrl& workerCtrl = ctrlQueue[static_cast<int>(qos)]; in IntoSleep() local22 workerCtrl.lock.lock(); in IntoSleep()23 workerCtrl.sleepingWorkerNum++; in IntoSleep()24 workerCtrl.executionNum--; in IntoSleep()25 workerCtrl.lock.unlock(); in IntoSleep()30 WorkerCtrl& workerCtrl = ctrlQueue[static_cast<int>(qos)]; in IntoPollWait() local31 std::lock_guard lk(workerCtrl.lock); in IntoPollWait()32 workerCtrl.pollWaitFlag = true; in IntoPollWait()