Searched refs:taskCount (Results 1 – 7 of 7) sorted by relevance
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTFiberContext.inl | 27 …id FiberContext::RunSubtasksAndYield(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount) argument
29 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run.");
34 ArrayView<internal::GroupedTask> buffer(threadContext->descBuffer, taskCount);
36 size_t bucketCount = MT::Min((size_t)scheduler.GetWorkersCount(), taskCount);
44 void FiberContext::RunAsync(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount) argument
46 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run.");
53 ArrayView<internal::GroupedTask> buffer(threadContext->descBuffer, taskCount);
55 size_t bucketCount = MT::Min((size_t)scheduler.GetWorkersCount(), taskCount);
|
| H A D | MTFiberContext.h | 70 void RunSubtasksAndYield(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount);
73 void RunAsync(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount);
|
| H A D | MTScheduler.inl | 102 void TaskScheduler::RunAsync(TaskGroup group, const TTask* taskArray, uint32 taskCount) argument
104 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run.");
107 uint32 bytesCountForGroupedTasks = sizeof(internal::GroupedTask) * taskCount;
108 …View<internal::GroupedTask> buffer( MT_ALLOCATE_ON_STACK( bytesCountForGroupedTasks ), taskCount );
110 uint32 bucketCount = MT::Min((uint32)GetWorkersCount(), taskCount);
|
| H A D | MTScheduler.h | 362 void RunAsync(TaskGroup group, const TTask* taskArray, uint32 taskCount);
|
| /TaskScheduler/SchedulerTests/Tests/ |
| H A D | WaitTests.cpp | 33 MT::Atomic32<int32> taskCount; in SUITE() variable
58 taskCount.IncFetch(); in SUITE()
67 taskCount.Store(0); in SUITE()
82 int taskCountFinished = taskCount.Load(); in SUITE()
|
| H A D | SimpleTests.cpp | 184 int32 taskCount = workersCount * TASK_COUNT_PER_WORKER; in SUITE() local
189 for(int32 i = 0; i < taskCount; i++) in SUITE()
213 CHECK_EQUAL(taskCount, (int32)finishedTaskCount.Load()); in SUITE()
215 printf("Yield test: %d tasks finished, used %d workers\n", taskCount, workersCount); in SUITE()
|
| /TaskScheduler/Scheduler/Source/ |
| H A D | MTScheduler.cpp | 742 int32 taskCount = groupDesc.GetTaskCount(); in WaitGroup() local
743 if (taskCount == 0) in WaitGroup()
777 int32 taskCount = allGroups.GetTaskCount(); in WaitAll() local
778 if (taskCount == 0) in WaitAll()
|