Searched refs:threadPool (Results 1 – 2 of 2) sorted by relevance
| /arkcompiler/runtime_core/static_core/runtime/tests/ |
| D | mock_queue_thread_pool.cpp | 171 void CreateTasks(ThreadPool<MockTask, MockProcessor, MockTaskController *> *threadPool, size_t numb… in CreateTasks() argument
177 threadPool->PutTask(std::move(task)); in CreateTasks()
186 auto threadPool = allocator->New<ThreadPool<MockTask, MockProcessor, MockTaskController *>>( in TestThreadPool() local
189 CreateTasks(threadPool, MockThreadPoolTest::TASK_NUMBER); in TestThreadPool()
194 threadPool->Scale(scaledNumberOfThreads); in TestThreadPool()
205 threadPool->Scale(dynamicScaling); in TestThreadPool()
213 allocator->Delete(threadPool); in TestThreadPool()
250 void ControllerThreadPutTask(ThreadPool<MockTask, MockProcessor, MockTaskController *> *threadPool, in ControllerThreadPutTask() argument
253 CreateTasks(threadPool, numberOfTasks); in ControllerThreadPutTask()
256 …d ControllerThreadTryPutTask(ThreadPool<MockTask, MockProcessor, MockTaskController *> *threadPool, in ControllerThreadTryPutTask() argument
[all …]
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| D | thread_pool.h | 249 static void WorkerEntry(ThreadPool<Task, Proc, ProcArg> *threadPool, Proc *proc, int i) in WorkerEntry() argument
251 WorkerCreationInterface *iface = threadPool->GetWorkerCreationInterface(); in WorkerEntry()
262 os::memory::LockHolder lock(threadPool->queueLock_); in WorkerEntry()
263 if (!threadPool->IsActive(i)) { in WorkerEntry()
266 task = std::move(threadPool->queue_->GetTask()); in WorkerEntry()
268 threadPool->WaitTask(); in WorkerEntry()
272 threadPool->SignalTask(); in WorkerEntry()
|