| /foundation/resourceschedule/ffrt/test/ut/ |
| H A D | worker_thread_test.cpp | 62 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
74 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
87 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
99 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
112 WorkerThread* wt = new WorkerThread(Qo in HWTEST_F()
[all...] |
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpu_manager_interface.h | 44 std::function<void (WorkerThread*)> WorkerLooper;
45 std::function<CPUEUTask* (WorkerThread*)> PickUpTask;
46 std::function<void (const WorkerThread*)> NotifyTaskPicked;
47 std::function<WorkerAction (const WorkerThread*)> WaitForNewAction;
48 std::function<void (WorkerThread*)> WorkerRetired;
49 std::function<void (WorkerThread*)> WorkerPrepare;
50 std::function<PollerRet (const WorkerThread*, int timeout)> TryPoll;
51 std::function<unsigned int (WorkerThread*)> StealTaskBatch;
52 std::function<CPUEUTask* (WorkerThread*)> PickUpTaskBatch;
54 std::function<bool (WorkerThread*)> IsExceedRunningThreshol
[all...] |
| H A D | cpuworker_manager.h | 76 virtual void WorkerPrepare(WorkerThread* thread) = 0;
89 void WorkerRetired(WorkerThread* thread);
91 bool IsExceedRunningThreshold(const WorkerThread* thread);
99 void NotifyTaskPicked(const WorkerThread* thread);
101 virtual CPUEUTask* PickUpTaskFromGlobalQueue(WorkerThread* thread) = 0;
102 CPUEUTask* PickUpTaskFromLocalQueue(WorkerThread* thread);
105 virtual WorkerAction WorkerIdleAction(const WorkerThread* thread) = 0;
107 void WorkerSetup(WorkerThread* thread);
108 PollerRet TryPoll(const WorkerThread* thread, int timeout = -1);
109 unsigned int StealTaskBatch(WorkerThread* threa
[all...] |
| H A D | worker_thread.cpp | 32 WorkerThread::WorkerThread(const QoS& qos) : exited(false), idle(false), tid(-1), qos(qos) in WorkerThread() function in ffrt::WorkerThread
46 void WorkerThread::NativeConfig() in NativeConfig()
53 void WorkerThread::WorkerSetup(WorkerThread* wthread) in WorkerSetup()
81 void SetThreadAttr(WorkerThread* thread, const QoS& qos) in SetThreadAttr()
|
| H A D | scpuworker_manager.h | 25 WorkerAction WorkerIdleAction(const WorkerThread* thread) override;
26 void WorkerPrepare(WorkerThread* thread) override;
28 CPUEUTask* PickUpTaskFromGlobalQueue(WorkerThread* thread) override;
29 CPUEUTask* PickUpTaskBatch(WorkerThread* thread) override;
|
| H A D | scpuworker_manager.cpp | 103 WorkerAction SCPUWorkerManager::WorkerIdleAction(const WorkerThread* thread) in WorkerIdleAction()
153 CPUEUTask* SCPUWorkerManager::PickUpTaskFromGlobalQueue(WorkerThread* thread) in PickUpTaskFromGlobalQueue()
165 CPUEUTask* SCPUWorkerManager::PickUpTaskBatch(WorkerThread* thread) in PickUpTaskBatch()
204 void SCPUWorkerManager::WorkerPrepare(WorkerThread* thread) in WorkerPrepare()
221 WorkerThread* CPUManagerStrategy::CreateCPUWorker(const QoS& qos, void* manager) in CreateCPUWorker()
233 [pIns] (WorkerThread* thread) { return pIns->PickUpTaskFromGlobalQueue(thread); }, in CreateCPUWorker()
234 [pIns] (const WorkerThread* thread) { pIns->NotifyTaskPicked(thread); }, in CreateCPUWorker()
235 [pIns] (const WorkerThread* thread) { return pIns->WorkerIdleAction(thread); }, in CreateCPUWorker()
236 [pIns] (WorkerThread* thread) { pIns->WorkerRetired(thread); }, in CreateCPUWorker()
237 [pIns] (WorkerThread* threa in CreateCPUWorker()
[all...] |
| H A D | cpuworker_manager.cpp | 61 auto uniqueWorker = std::unique_ptr<WorkerThread>(worker); in IncWorker()
93 CPUEUTask* CPUWorkerManager::PickUpTaskFromLocalQueue(WorkerThread* thread) in PickUpTaskFromLocalQueue()
104 unsigned int CPUWorkerManager::StealTaskBatch(WorkerThread* thread) in StealTaskBatch()
116 std::unordered_map<WorkerThread*, std::unique_ptr<WorkerThread>>::iterator iter = in StealTaskBatch()
133 PollerRet CPUWorkerManager::TryPoll(const WorkerThread* thread, int timeout) in TryPoll()
162 void CPUWorkerManager::NotifyTaskPicked(const WorkerThread* thread) in NotifyTaskPicked()
167 void CPUWorkerManager::WorkerRetired(WorkerThread* thread) in WorkerRetired()
247 bool CPUWorkerManager::IsExceedRunningThreshold(const WorkerThread* thread) in IsExceedRunningThreshold()
|
| H A D | cpu_worker.h | 29 class CPUWorker : public WorkerThread {
31 CPUWorker(const QoS& qos, CpuWorkerOps&& ops) : WorkerThread(qos), ops(ops) in CPUWorker()
50 static void WorkerLooperDefault(WorkerThread* p);
|
| H A D | worker_thread.h | 42 class WorkerThread { class
49 explicit WorkerThread(const QoS& qos);
51 virtual ~WorkerThread() in ~WorkerThread()
55 FFRT_LOGW("WorkerThread enter destruction but not exited"); in ~WorkerThread()
72 FFRT_LOGW("WorkerThread enter destruction"); in ~WorkerThread()
191 void WorkerSetup(WorkerThread* wthread);
211 void SetThreadAttr(WorkerThread* thread, const QoS& qos);
|
| H A D | worker_manager.h | 38 std::unordered_map<WorkerThread*, std::unique_ptr<WorkerThread>> threads;
|
| H A D | qos_interface.h | 208 typedef void (*Func_priority)(unsigned char priority, ffrt::WorkerThread* thread);
|
| H A D | cpu_worker.cpp | 221 void CPUWorker::WorkerLooperDefault(WorkerThread* p) in WorkerLooperDefault()
|
| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_thread.cpp | 78 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
85 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
93 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
100 WorkerThread* wt = new WorkerThread(QoS(6)); in HWTEST_F()
108 WorkerThread* wt = new WorkerThread(Qo in HWTEST_F()
[all...] |
| H A D | ut_worker_manager.cpp | 132 WorkerThread* worker = CPUManagerStrategy::CreateCPUWorker(QoS(2), manager); in HWTEST_F()
160 WorkerThread* worker = new CPUWorker(QoS(2), std::move(ops), manager); in HWTEST_F()
|
| /foundation/resourceschedule/ffrt/src/util/ |
| H A D | worker_monitor.h | 86 void RecordTimeoutFunctionInfo(const CoWorkerInfo& coWorkerInfo, WorkerThread* worker,
97 std::map<WorkerThread*, TaskTimeoutInfo> workerStatus_;
|
| H A D | worker_monitor.cpp | 182 WorkerThread* worker = thread.first; in CheckWorkerStatus()
200 void WorkerMonitor::RecordTimeoutFunctionInfo(const CoWorkerInfo& coWorkerInfo, WorkerThread* worker, in RecordTimeoutFunctionInfo()
|