| /TaskScheduler/SchedulerTests/Tests/ |
| H A D | WaitTests.cpp | 55 Subtask tasks[2]; in SUITE() local
56 ctx.RunSubtasksAndYield(testGroup, &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
74 Task tasks[16]; in SUITE() local
75 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
83 CHECK_EQUAL(MT_ARRAY_SIZE(tasks), (size_t)taskCountFinished); in SUITE()
102 LongTask tasks[4000]; in SUITE() local
103 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
120 LongTask tasks[4000]; in SUITE() local
121 scheduler.RunAsync(myGroup, &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
163 SecondaryTask tasks[64]; in SUITE() local
[all …]
|
| H A D | SubtasksTests.cpp | 223 TaskSubtaskCombo_Sum1 tasks[2]; in SUITE() member
227 tasks[0].data = data; in SUITE()
228 tasks[1].data = data; 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()
241 TaskSubtaskCombo_Sum4 tasks[2]; in SUITE() member
245 tasks[0].data = data; in SUITE()
246 tasks[1].data = data; in SUITE()
248 context.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
249 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
|
| H A D | StackSizeTests.cpp | 69 StandartStackSizeTask tasks[100]; in SUITE() local
70 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
79 ExtendedStackSizeTask tasks[100]; in SUITE() local
80 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
|
| H A D | CleanupTests.cpp | 47 NotFinishedTaskDestroy tasks[1024]; in SUITE() local
49 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
|
| H A D | SimpleTests.cpp | 87 ALotOfTasks tasks[TASK_COUNT]; in SUITE() local
89 for (size_t i = 0; i < MT_ARRAY_SIZE(tasks); ++i) in SUITE()
90 tasks[i].counter = &counter; in SUITE()
92 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
188 MT::StaticVector<YieldTask, 512> tasks; in SUITE() local
191 tasks.PushBack(YieldTask()); in SUITE()
201 scheduler.RunAsync(MT::TaskGroup::Default(), tasks.Begin(), (uint32)tasks.Size()); in SUITE()
|
| H A D | FireAndForget.cpp | 179 ThreadTest tasks[8]; in SUITE() local
180 for (size_t i = 0; i < MT_ARRAY_SIZE(tasks); ++i) in SUITE()
182 tasks[i].taskPool = &taskPool; in SUITE()
185 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
|
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTTaskBucket.h | 37 GroupedTask* tasks; member
40 : tasks(_tasks) in TaskBucket()
|
| H A D | MTFiberContext.inl | 29 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run.");
46 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run.");
|
| H A D | MTScheduler.inl | 104 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run.");
|
| /TaskScheduler/.vscode/ |
| H A D | tasks.json | 3 // for the documentation about the tasks.json format
|
| /TaskScheduler/ |
| H A D | README.md | 43 // Declare tasks
45 SimpleTask tasks[TASK_COUNT];
48 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks));
50 // Wait and help to execute unfinished tasks
|
| /TaskScheduler/Scheduler/Source/ |
| H A D | MTScheduler.cpp | 658 internal::GroupedTask & task = bucket.tasks[taskIndex]; in RunTasksImpl()
707 bool res = context.queue.Add(bucket.tasks, bucket.count); in RunTasksImpl()
|