Home
last modified time | relevance | path

Searched refs:TaskGroup (Results 1 – 18 of 18) sorted by relevance

/TaskScheduler/Scheduler/Include/
H A DMTTaskGroup.h29 class TaskGroup
45 TaskGroup() in TaskGroup() function
50 explicit TaskGroup(PredefinedValues v) in TaskGroup() function
55 explicit TaskGroup(int16 _id) in TaskGroup() function
60 static TaskGroup Default() in Default()
62 return TaskGroup(DEFAULT); in Default()
65 TaskGroup & operator= (const PredefinedValues & v)
76 bool operator== (const TaskGroup & other) const
81 bool operator!= (const TaskGroup & other) const
H A DMTFiberContext.h70 void RunSubtasksAndYield(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount);
73 void RunAsync(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount);
76 void RunAsync(TaskGroup taskGroup, const TaskHandle* taskHandleArray, uint32 taskHandleCount);
77 …void RunSubtasksAndYield(TaskGroup taskGroup, const TaskHandle* taskHandleArray, uint32 taskHandle…
104 TaskGroup currentGroup;
H A DMTGroupedTask.h41 TaskGroup group;
49 GroupedTask(const TaskDesc& _desc, TaskGroup _group) in GroupedTask()
H A DMTScheduler.h312 LockFreeQueueMPMC<TaskGroup, TaskGroup::MT_MAX_GROUPS_COUNT * 2> availableGroups;
315 TaskGroupDescription groupStats[TaskGroup::MT_MAX_GROUPS_COUNT];
334 TaskGroupDescription & GetGroupDesc(TaskGroup group);
362 void RunAsync(TaskGroup group, const TTask* taskArray, uint32 taskCount);
364 void RunAsync(TaskGroup group, const TaskHandle* taskHandleArray, uint32 taskHandleCount);
368 bool WaitGroup(TaskGroup group, uint32 milliseconds);
372 TaskGroup CreateGroup();
373 void ReleaseGroup(TaskGroup group);
H A DMTScheduler.inl30 inline internal::GroupedTask GetGroupedTask(TaskGroup group, const T * src)
42 inline internal::GroupedTask GetGroupedTask(TaskGroup group, FiberContext* const * src)
45 MT_ASSERT(group == TaskGroup::ASSIGN_FROM_CONTEXT, "Group must be assigned from context");
55 inline internal::GroupedTask GetGroupedTask(TaskGroup group, const MT::TaskHandle * src)
74 …inline bool DistibuteDescriptions(TaskGroup group, TTask* taskArray, ArrayView<internal::GroupedTa…
102 void TaskScheduler::RunAsync(TaskGroup group, const TTask* taskArray, uint32 taskCount)
H A DMTFiberContext.inl27 …void FiberContext::RunSubtasksAndYield(TaskGroup taskGroup, const TTask* taskArray, size_t taskCou…
44 void FiberContext::RunAsync(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount)
/TaskScheduler/SchedulerTests/Tests/
H A DSubtasksTests.cpp57 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &taskNm1, 1); in SUITE()
58 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &taskNm2, 1); in SUITE()
96 scheduler.RunAsync(MT::TaskGroup::Default(), &task, 1); in SUITE()
104 static MT::TaskGroup sourceGroup; in SUITE()
105 static MT::TaskGroup resultGroup; in SUITE()
137 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &task, 1); in SUITE()
167 scheduler.RunAsync(MT::TaskGroup::Default(), &task, 1); in SUITE()
230 context.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
231 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
248 context.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
[all …]
H A DWaitTests.cpp35 MT::TaskGroup testGroup; in SUITE()
75 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
103 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
118 MT::TaskGroup myGroup = scheduler.CreateGroup(); in SUITE()
152 MT::TaskGroup secondaryGroup; in SUITE()
156 PrimaryTask(MT::TaskGroup _secondaryGroup) in SUITE()
179 MT::TaskGroup mainGroup = scheduler.CreateGroup(); in SUITE()
180 MT::TaskGroup secondaryGroup = scheduler.CreateGroup(); in SUITE()
H A DGroupTests.cpp70 ctx.RunSubtasksAndYield(MT::TaskGroup::Default(), &subtasks[0], MT_ARRAY_SIZE(subtasks)); in SUITE()
91 ctx.RunSubtasksAndYield(MT::TaskGroup::Default(), &subtasks[0], MT_ARRAY_SIZE(subtasks)); in SUITE()
109 MT::TaskGroup groupEmpty = scheduler.CreateGroup(); in SUITE()
110 MT::TaskGroup groupAnim = scheduler.CreateGroup(); in SUITE()
119 MT::TaskGroup groupPhysic = scheduler.CreateGroup(); in SUITE()
H A DSimpleTests.cpp57 scheduler.RunAsync(MT::TaskGroup::Default(), &task, 1); in SUITE()
92 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
96 CHECK(scheduler.WaitGroup(MT::TaskGroup::Default(), timeout)); in SUITE()
201 scheduler.RunAsync(MT::TaskGroup::Default(), tasks.Begin(), (uint32)tasks.Size()); in SUITE()
203 CHECK(scheduler.WaitGroup(MT::TaskGroup::Default(), 10000)); in SUITE()
H A DStackSizeTests.cpp70 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
80 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
107 scheduler.RunAsync(MT::TaskGroup::Default(), &taskHandles[0], MT_ARRAY_SIZE(taskHandles)); in SUITE()
H A DFireAndForget.cpp87 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &handle, 1); in SUITE()
185 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
188 CHECK(scheduler.WaitGroup(MT::TaskGroup::Default(), timeout)); in SUITE()
215 scheduler.RunAsync(MT::TaskGroup::Default(), &taskHandles[0], MT_ARRAY_SIZE(taskHandles)); in SUITE()
H A DCleanupTests.cpp49 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
H A DDxtTests.cpp216 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &subTasks[0], subTasks.Size()); in SUITE()
361 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &subTasks[0], subTasks.Size()); in SUITE()
489 scheduler.RunAsync(MT::TaskGroup::Default(), &compressTask, 1); in SUITE()
497 scheduler.RunAsync(MT::TaskGroup::Default(), &decompressTask, 1); in SUITE()
H A DPriorityTests.cpp204 scheduler.RunAsync(MT::TaskGroup::Default(), &taskHandles[0], MT_ARRAY_SIZE(taskHandles)); in SUITE()
/TaskScheduler/Scheduler/Source/
H A DMTScheduler.cpp88 for (int16 i = 0; i < TaskGroup::MT_MAX_GROUPS_COUNT; i++) in TaskScheduler()
90 if (i != TaskGroup::DEFAULT) in TaskScheduler()
92 bool res = availableGroups.TryPush( TaskGroup(i) ); in TaskScheduler()
99 groupStats[TaskGroup::DEFAULT].SetDebugIsFree(false); in TaskScheduler()
257 TaskGroup taskGroup = fiberContext->currentGroup; in ExecuteTask()
266 fiberContext->currentGroup = TaskGroup::INVALID; in ExecuteTask()
603 …internal::DistibuteDescriptions( TaskGroup(TaskGroup::ASSIGN_FROM_CONTEXT), yieldedTasksQueue.Begi… in SchedulerFiberProcessTask()
644 int newTaskCountInGroup[TaskGroup::MT_MAX_GROUPS_COUNT]; in RunTasksImpl()
843 TaskGroup TaskScheduler::CreateGroup() in CreateGroup()
847 TaskGroup group; in CreateGroup()
[all …]
H A DMTFiberContext.cpp130 …void FiberContext::RunAsync(TaskGroup taskGroup, const TaskHandle* taskHandleArray, uint32 taskHan… in RunAsync()
149 …void FiberContext::RunSubtasksAndYield(TaskGroup taskGroup, const TaskHandle* taskHandleArray, uin… in RunSubtasksAndYield()
/TaskScheduler/
H A DREADME.md48 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks));