Home
last modified time | relevance | path

Searched refs:groupCtl (Results 1 - 5 of 5) sorted by relevance

/foundation/resourceschedule/ffrt/src/eu/
H A Dcpuworker_manager.cpp54 std::unique_lock<std::shared_mutex> lock(groupCtl[workerQos].tgMutex); in IncWorker()
67 auto result = groupCtl[workerQos].threads.emplace(worker, std::move(uniqueWorker)); in IncWorker()
88 std::shared_lock<std::shared_mutex> lck(groupCtl[qos()].tgMutex); in GetWorkerCount()
89 return groupCtl[qos()].threads.size(); in GetWorkerCount()
110 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) { in StealTaskBatch()
114 std::shared_lock<std::shared_mutex> lck(groupCtl[thread->GetQos()].tgMutex); in StealTaskBatch()
117 groupCtl[thread->GetQos()].threads.begin(); in StealTaskBatch()
118 while (iter != groupCtl[thread->GetQos()].threads.end()) { in StealTaskBatch()
173 std::unique_lock<std::shared_mutex> lck(groupCtl[qos].tgMutex); in WorkerRetired()
176 auto worker = std::move(groupCtl[qo in WorkerRetired()
[all...]
H A Dworker_manager.cpp22 auto& tgwrap = groupCtl[qos]; in JoinRtg()
34 auto& tgwrap = groupCtl[qos]; in JoinTG()
61 auto& tgwrap = groupCtl[qos]; in LeaveTG()
74 for (auto& thread : groupCtl[qos].threads) { in LeaveTG()
H A Dworker_manager.h61 return groupCtl; in GetGroupCtl()
65 WorkerGroupCtl groupCtl[QoS::MaxNum()]; member in ffrt::WorkerManager
H A Dscpuworker_manager.cpp60 std::shared_lock<std::shared_mutex> lck(groupCtl[qos].tgMutex); in ~SCPUWorkerManager()
61 if (groupCtl[qos].threads.empty()) { in ~SCPUWorkerManager()
80 std::unique_lock<std::shared_mutex> lck(groupCtl[qos].tgMutex); in AddDelayedTask()
81 bool isEmpty = groupCtl[qos].threads.empty(); in AddDelayedTask()
/foundation/resourceschedule/ffrt/src/core/
H A Dtask.cpp435 ffrt::WorkerGroupCtl* groupCtl = ffrt::FFRTFacade::GetEUInstance().GetGroupCtl(); in ffrt_set_worker_stack_size() local
436 std::unique_lock<std::shared_mutex> lck(groupCtl[qos].tgMutex); in ffrt_set_worker_stack_size()
437 if (!groupCtl[qos].threads.empty()) { in ffrt_set_worker_stack_size()
448 groupCtl[qos].workerStackSize = (stack_size - 1 + static_cast<size_t>(pageSize)) & in ffrt_set_worker_stack_size()

Completed in 3 milliseconds