Lines Matching refs:GetQos
110 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) {
114 std::shared_lock<std::shared_mutex> lck(groupCtl[thread->GetQos()].tgMutex);
115 AddStealingWorker(thread->GetQos());
117 groupCtl[thread->GetQos()].threads.begin();
118 while (iter != groupCtl[thread->GetQos()].threads.end()) {
123 reinterpret_cast<CPUWorker*>(thread)->localFifo, (queueLen + 1) / 2, thread->GetQos(), InsertTask);
124 SubStealingWorker(thread->GetQos());
129 SubStealingWorker(thread->GetQos());
135 if (tearDown || FFRTFacade::GetPPInstance().GetPoller(thread->GetQos()).DetermineEmptyMap()) {
138 auto& pollerMtx = pollersMtx[thread->GetQos()];
140 polling_[thread->GetQos()] = 1;
142 monitor->IntoPollWait(thread->GetQos());
144 PollerRet ret = FFRTFacade::GetPPInstance().GetPoller(thread->GetQos()).PollOnce(timeout);
146 monitor->OutOfPollWait(thread->GetQos());
148 polling_[thread->GetQos()] = 0;
164 monitor->Notify(thread->GetQos(), TaskNotifyType::TASK_PICKED);
170 int qos = static_cast<int>(thread->GetQos());
249 return monitor->IsExceedRunningThreshold(thread->GetQos());