Lines Matching refs:groupCtl
54 std::unique_lock<std::shared_mutex> lock(groupCtl[workerQos].tgMutex);
67 auto result = groupCtl[workerQos].threads.emplace(worker, std::move(uniqueWorker));
88 std::shared_lock<std::shared_mutex> lck(groupCtl[qos()].tgMutex);
89 return groupCtl[qos()].threads.size();
110 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) {
114 std::shared_lock<std::shared_mutex> lck(groupCtl[thread->GetQos()].tgMutex);
117 groupCtl[thread->GetQos()].threads.begin();
118 while (iter != groupCtl[thread->GetQos()].threads.end()) {
173 std::unique_lock<std::shared_mutex> lck(groupCtl[qos].tgMutex);
176 auto worker = std::move(groupCtl[qos].threads[thread]);
177 int ret = groupCtl[qos].threads.erase(thread);
206 groupCtl[qos_deadline_request].tg = std::make_unique<ThreadGroup>();
211 std::shared_lock<std::shared_mutex> lock(groupCtl[qos()].tgMutex);
216 auto& tgwrap = groupCtl[qos()];
234 auto& tgwrap = groupCtl[qos()];