| /arkcompiler/runtime_core/static_core/libpandabase/taskmanager/ |
| D | task_queue_interface.h | 30 class TaskQueueInterface {
32 NO_COPY_SEMANTIC(TaskQueueInterface);
33 NO_MOVE_SEMANTIC(TaskQueueInterface);
35 …PANDA_PUBLIC_API explicit TaskQueueInterface(QueuePriority priority = DEFAULT_QUEUE_PRIORITY) : pr… in priority_()
39 PANDA_PUBLIC_API virtual ~TaskQueueInterface() = default;
79 inline QueuePriority TaskQueueInterface::GetPriority() const in GetPriority()
85 inline void TaskQueueInterface::SetPriority(QueuePriority priority) in SetPriority()
92 inline QueueId TaskQueueInterface::GetQueueId() const in GetQueueId()
97 inline void TaskQueueInterface::Register(QueueId id) in Register()
|
| D | task_queue_set.h | 35 TaskQueueInterface *CreateQueue(QueuePriority priority);
37 void DeleteQueue(TaskQueueInterface *queue);
38 TaskQueueInterface *GetQueue(QueueId id);
39 TaskQueueInterface *SelectQueue();
55 std::array<std::atomic<TaskQueueInterface *>, MAX_COUNT_OF_QUEUE> queues_ {};
61 inline TaskQueueInterface *TaskQueueSet::CreateQueue(QueuePriority priority) in CreateQueue()
71 TaskQueueInterface *nullp = nullptr; in CreateQueue()
87 inline void TaskQueueSet::DeleteQueue(TaskQueueInterface *queue) in DeleteQueue()
|
| D | task.h | 25 class TaskQueueInterface; variable
45 PANDA_PUBLIC_API void GetTimeOfTaskExecutionFinishAndStoreTimeStats(TaskQueueInterface *queue);
55 using OnDestructionCallback = void (*)(TaskQueueInterface *);
67 … [[nodiscard]] PANDA_PUBLIC_API static Ptr Create(RunnerCallback runner, TaskQueueInterface *queue,
77 Task(RunnerCallback runner, TaskQueueInterface *queue, OnDestructionCallback callback) in Task()
90 TaskQueueInterface *parentQueue_ {nullptr};
|
| D | task_manager.h | 65 …static PANDA_PUBLIC_API TaskQueueInterface *CreateTaskQueue(QueuePriority priority = DEFAULT_QUEUE…
67 static PANDA_PUBLIC_API TaskQueueInterface *GetTaskQueue(QueueId id);
73 static PANDA_PUBLIC_API void DestroyTaskQueue(TaskQueueInterface *queue);
100 inline PANDA_PUBLIC_API TaskQueueInterface *TaskManager::CreateTaskQueue(QueuePriority priority) in CreateTaskQueue()
107 inline PANDA_PUBLIC_API void TaskManager::DestroyTaskQueue(TaskQueueInterface *queue) in DestroyTaskQueue()
|
| D | task_scheduler.h | 28 class TaskQueueInterface; variable
74 PANDA_PUBLIC_API size_t HelpWorkersWithTasks(TaskQueueInterface *queue);
114 size_t GetAndExecuteSetOfTasksFromQueue(TaskQueueInterface *properties);
122 size_t StealAndExecuteOneTaskFromWorkers(TaskQueueInterface *properties);
|
| D | task_queue_set.cpp | 58 TaskQueueInterface *TaskQueueSet::GetQueue(QueueId id) in GetQueue()
65 TaskQueueInterface *TaskQueueSet::SelectQueue() in SelectQueue()
68 std::array<TaskQueueInterface *, MAX_COUNT_OF_QUEUE> queues {}; in SelectQueue()
|
| D | task.cpp | 32 void TaskLifeTimeAggregator::GetTimeOfTaskExecutionFinishAndStoreTimeStats(TaskQueueInterface *queu… in GetTimeOfTaskExecutionFinishAndStoreTimeStats()
42 Task::Ptr Task::Create(RunnerCallback runner, TaskQueueInterface *queue, OnDestructionCallback call… in Create()
|
| D | schedulable_task_queue_interface.h | 25 class SchedulableTaskQueueInterface : public TaskQueueInterface {
43 explicit SchedulableTaskQueueInterface(QueuePriority priority) : TaskQueueInterface(priority) {} in SchedulableTaskQueueInterface()
|
| D | task_manager.cpp | 44 TaskQueueInterface *TaskManager::GetTaskQueue(QueueId id) in GetTaskQueue()
|
| D | task_queue.h | 103 static void OnForegroundTaskDestructionCallback(TaskQueueInterface *queue);
104 static void OnBackgroundTaskDestructionCallback(TaskQueueInterface *queue);
150 inline void TaskQueue<Allocator>::OnForegroundTaskDestructionCallback(TaskQueueInterface *queue) in OnForegroundTaskDestructionCallback()
162 inline void TaskQueue<Allocator>::OnBackgroundTaskDestructionCallback(TaskQueueInterface *queue) in OnBackgroundTaskDestructionCallback()
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| D | thread_pool_queue.h | 31 class TaskQueueInterface {
34 …explicit TaskQueueInterface(size_t queueMaxSize = QUEUE_SIZE_MAX_SIZE) : queueMaxSize_(queueMaxSiz… in queueMaxSize_()
35 virtual ~TaskQueueInterface() = default;
37 NO_COPY_SEMANTIC(TaskQueueInterface);
38 NO_MOVE_SEMANTIC(TaskQueueInterface);
|
| D | compiler_queue_interface.h | 26 class CompilerQueueInterface : public TaskQueueInterface<CompilerTask> {
|
| D | compiler_task_manager_worker.h | 62 taskmanager::TaskQueueInterface *compilerTaskManagerQueue_ {nullptr};
|
| D | thread_pool.h | 95 …explicit ThreadPool(mem::InternalAllocatorPtr allocator, TaskQueueInterface<Task> *queue, ProcArg …
381 TaskQueueInterface<Task> *queue_ GUARDED_BY(queueLock_);
|
| /arkcompiler/runtime_core/static_core/libpandabase/tests/taskmanager/ |
| D | task_scheduler_test.cpp | 42 std::thread *CreateTaskProducerThread(TaskQueueInterface *queue) in CreateTaskProducerThread()
110 TaskQueueInterface *queue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
124 TaskQueueInterface *gcQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
125 TaskQueueInterface *jitQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
161 TaskQueueInterface *gcQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
162 TaskQueueInterface *jitQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
262 TaskQueueInterface *gcQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
263 TaskQueueInterface *jitQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
298 TaskQueueInterface *gcQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
332 TaskQueueInterface *gcQueue = TaskManager::CreateTaskQueue(QUEUE_PRIORITY); in TEST_F()
[all …]
|
| D | task_manager_gc_corner_case_test.cpp | 47 void SetQueue(TaskQueueInterface *queue) in SetQueue()
52 TaskQueueInterface *GetQueue() in GetQueue()
117 TaskQueueInterface *queue_ {nullptr};
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/workers/ |
| D | gc_workers_thread_pool.h | 44 class GCWorkersQueueSimple : public TaskQueueInterface<GCWorkersTask> {
47 : TaskQueueInterface<GCWorkersTask>(queueLimit), queue_(allocator->Adapter()) in GCWorkersQueueSimple()
|
| /arkcompiler/runtime_core/static_core/compiler/ |
| D | background_task_runner.h | 196 …BackgroundCompilerTaskRunner(taskmanager::TaskQueueInterface *compilerQueue, Thread *compilerThrea… in BackgroundCompilerTaskRunner()
225 taskmanager::TaskQueueInterface *compilerQueue_ {nullptr};
|
| /arkcompiler/runtime_core/static_core/runtime/tests/ |
| D | mock_queue_thread_pool.cpp | 88 class MockQueue : public TaskQueueInterface<MockTask> {
92 : TaskQueueInterface<MockTask>(queueSize), queue_(allocator->Adapter()) in MockQueue()
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/ |
| D | gc.h | 340 taskmanager::TaskQueueInterface *GetWorkersTaskQueue() const in GetWorkersTaskQueue()
759 taskmanager::TaskQueueInterface *gcWorkersTaskQueue_ = nullptr;
|
| /arkcompiler/runtime_core/static_core/models/thread_pool/ |
| D | thread_pool.tla | 97 \* TaskQueueInterface methods
|