| /arkcompiler/runtime_core/static_core/libpandabase/taskmanager/ |
| D | task_scheduler.cpp | 21 TaskScheduler *TaskScheduler::instance_ = nullptr;
23 TaskScheduler::TaskScheduler(size_t workersCount, TaskTimeStatsType taskTimeStatsType) in TaskScheduler() function in ark::taskmanager::TaskScheduler
38 TaskScheduler *TaskScheduler::Create(size_t threadsCount, TaskTimeStatsType taskTimeStatsType) in Create()
42 instance_ = new TaskScheduler(threadsCount, taskTimeStatsType); in Create()
47 TaskScheduler *TaskScheduler::GetTaskScheduler() in GetTaskScheduler()
53 void TaskScheduler::Destroy() in Destroy()
60 TaskQueueId TaskScheduler::RegisterQueue(internal::SchedulableTaskQueueInterface *queue) in RegisterQueue()
82 void TaskScheduler::Initialize() in Initialize()
105 void TaskScheduler::StealTaskFromOtherWorker(WorkerThread *taskReceiver) in StealTaskFromOtherWorker()
120 bool TaskScheduler::FillWithTasks(WorkerThread *worker) in FillWithTasks()
[all …]
|
| D | task_scheduler.h | 34 class TaskScheduler {
38 NO_COPY_SEMANTIC(TaskScheduler);
39 NO_MOVE_SEMANTIC(TaskScheduler);
50 PANDA_PUBLIC_API static TaskScheduler *Create(size_t threadsCount,
57 [[nodiscard]] PANDA_PUBLIC_API static TaskScheduler *GetTaskScheduler();
185 PANDA_PUBLIC_API ~TaskScheduler();
188 explicit TaskScheduler(size_t workersCount, TaskTimeStatsType taskTimeStatsType);
264 static TaskScheduler *instance_;
|
| D | task.cpp | 33 auto *scheduler = TaskScheduler::GetTaskScheduler(); in GetTimeOfTaskExecutionFinishAndStoreTimeStats()
75 auto *scheduler = TaskScheduler::GetTaskScheduler(); in EventOnTaskAdding()
86 auto *scheduler = TaskScheduler::GetTaskScheduler(); in EventOnStartExecution()
97 auto *scheduler = TaskScheduler::GetTaskScheduler(); in EventOnEndExecution()
|
| D | worker_thread.cpp | 23 WorkerThread::WorkerThread(const std::string &name) : scheduler_(TaskScheduler::GetTaskScheduler())… in WorkerThread()
59 auto *scheduler = TaskScheduler::GetTaskScheduler(); in WorkerLoop()
62 TaskScheduler::GetTaskScheduler()->GetTaskTimeStats()->RegisterWorkerThread(); in WorkerLoop()
|
| D | worker_thread.h | 30 class TaskScheduler; variable
144 TaskScheduler *scheduler_ = nullptr;
|
| /arkcompiler/runtime_core/static_core/libpandabase/tests/taskmanager/ |
| D | task_manager_gc_corner_case_test.cpp | 63 size_t count = TaskScheduler::GetTaskScheduler()->HelpWorkersWithTasks(FOREGROUND_TASK); in GetAndRunForegroundTasks()
74 TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(FOREGROUND_TASK); in BigGcTask()
78 TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(FOREGROUND_TASK); in BigGcTask()
82 TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(FOREGROUND_TASK); in BigGcTask()
88 TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(FOREGROUND_TASK); in BigGcTask()
110 TaskScheduler::Create(COUNT_OF_WORKERS, TaskTimeStatsType::NO_STATISTICS); in SetUp()
115 TaskScheduler::Destroy(); in TearDown()
125 auto *tm = TaskScheduler::GetTaskScheduler(); in TEST_F()
138 auto *tm = TaskScheduler::GetTaskScheduler(); in TEST_F()
|
| D | task_scheduler_test.cpp | 115 auto *tm = TaskScheduler::Create(THREADS_COUNT); in TEST_F()
121 TaskScheduler::Destroy(); in TEST_F()
129 auto *tm = TaskScheduler::Create(THREADS_COUNT); in TEST_F()
159 TaskScheduler::Destroy(); in TEST_F()
167 auto *tm = TaskScheduler::Create(THREADS_COUNT); in TEST_F()
197 TaskScheduler::Destroy(); in TEST_F()
205 auto *tm = TaskScheduler::Create(THREADS_COUNT); in TEST_F()
237 TaskScheduler::Destroy(); in TEST_F()
245 auto *tm = TaskScheduler::Create(THREADS_COUNT); in TEST_F()
276 TaskScheduler::Destroy(); in TEST_F()
[all …]
|
| D | task_sheduler_logging_test.cpp | 35 auto *tm = TaskScheduler::Create(THREADS_COUNT, TaskTimeStatsType::LIGHT_STATISTICS); in TEST()
62 TaskScheduler::Destroy(); in TEST()
68 auto *tm = TaskScheduler::Create(THREADS_COUNT, TaskTimeStatsType::NO_STATISTICS); in TEST()
88 TaskScheduler::Destroy(); in TEST()
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/g1/ |
| D | update_remset_task_queue.cpp | 84 taskmanager::TaskScheduler::GetTaskScheduler()->SignalWaitList(taskRunnerWaiterId_); in ContinueProcessCards()
101 …taskmanager::TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(UPDATE_REMSET_… in DestroyWorkerImpl()
112 … taskmanager::TaskScheduler::GetTaskScheduler()->AddTaskToWaitList(std::move(processCardsTask)); in AddToWaitList()
121 …taskRunnerWaiterId_ = taskmanager::TaskScheduler::GetTaskScheduler()->AddTaskToWaitListWithTimeout( in AddToWaitListWithTimeout()
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| D | compiler_task_manager_worker.cpp | 26 auto *tm = taskmanager::TaskScheduler::GetTaskScheduler(); in CompilerTaskManagerWorker()
38 …taskmanager::TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(JIT_TASK_PROPE… in JoinWorker()
|
| D | compiler_task_manager_worker.h | 60 taskmanager::TaskScheduler::GetTaskScheduler() in ~CompilerTaskManagerWorker()
|
| D | runtime.cpp | 85 taskmanager::TaskScheduler *Runtime::taskScheduler_ = nullptr;
475 taskmanager::TaskScheduler::Destroy(); in Destroy()
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/workers/ |
| D | gc_workers_task_queue.cpp | 37 taskmanager::TaskScheduler::GetTaskScheduler()->HelpWorkersWithTasks(GC_TASK_PROPERTIES); in RunInCurrentThread()
|
| D | gc_worker.cpp | 85 …taskmanager::TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(GC_WORKER_TASK… in FinalizeAndDestroyWorker()
|
| /arkcompiler/runtime_core/static_core/runtime/include/ |
| D | runtime.h | 158 static void SetTaskScheduler(taskmanager::TaskScheduler *taskScheduler) in SetTaskScheduler()
165 static taskmanager::TaskScheduler *GetTaskScheduler() in GetTaskScheduler()
501 static taskmanager::TaskScheduler *taskScheduler_;
|
| /arkcompiler/runtime_core/static_core/compiler/docs/ |
| D | compilation_start.md | 5 - background mode starts compilation in worker thread of `taskmanager::TaskScheduler` (asynchronous…
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/ |
| D | gc.cpp | 59 auto *tm = taskmanager::TaskScheduler::GetTaskScheduler(); in GC()
88 …taskmanager::TaskScheduler::GetTaskScheduler()->UnregisterAndDestroyTaskQueue<decltype(allocator->… in ~GC()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| D | ets_vm.cpp | 76 auto *taskScheduler = taskmanager::TaskScheduler::Create( in CreateTaskManagerIfNeeded()
|