Home
last modified time | relevance | path

Searched refs:buckets (Results 1 – 6 of 6) sorted by relevance

/TaskScheduler/Scheduler/Source/
H A DMTFiberContext.cpp95 void FiberContext::RunSubtasksAndYieldImpl(ArrayView<internal::TaskBucket>& buckets) in RunSubtasksAndYieldImpl() argument
103 threadContext->taskScheduler->RunTasksImpl(buckets, this, false); in RunSubtasksAndYieldImpl()
142 …ArrayView<internal::TaskBucket> buckets(MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket) * bucket… in RunAsync() local
144 internal::DistibuteDescriptions(taskGroup, taskHandleArray, buffer, buckets); in RunAsync()
145 scheduler.RunTasksImpl(buckets, nullptr, false); in RunAsync()
160 …ArrayView<internal::TaskBucket> buckets(MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket) * bucket… in RunSubtasksAndYield() local
162 internal::DistibuteDescriptions(taskGroup, taskHandleArray, buffer, buckets); in RunSubtasksAndYield()
163 RunSubtasksAndYieldImpl(buckets); in RunSubtasksAndYield()
H A DMTScheduler.cpp599 … ArrayView<internal::TaskBucket> buckets( MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket)), 1 ); in SchedulerFiberProcessTask() local
603 …criptions( TaskGroup(TaskGroup::ASSIGN_FROM_CONTEXT), yieldedTasksQueue.Begin(), buffer, buckets ); in SchedulerFiberProcessTask()
606 context.taskScheduler->RunTasksImpl(buckets, nullptr, true); in SchedulerFiberProcessTask()
634 for (size_t i = 0; i < buckets.Size(); ++i) in RunTasksImpl()
653 for (size_t i = 0; i < buckets.Size(); ++i) in RunTasksImpl()
655 internal::TaskBucket& bucket = buckets[i]; in RunTasksImpl()
696 for (size_t i = 0; i < buckets.Size(); ++i) in RunTasksImpl()
701 internal::TaskBucket& bucket = buckets[i]; in RunTasksImpl()
729 …ArrayView<internal::TaskBucket> buckets(MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket) * bucket… in RunAsync() local
731 internal::DistibuteDescriptions(group, taskHandleArray, buffer, buckets); in RunAsync()
[all …]
/TaskScheduler/Scheduler/Include/
H A DMTFiberContext.inl37 …ArrayView<internal::TaskBucket> buckets(MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket) * bucket… local
39 internal::DistibuteDescriptions(taskGroup, taskArray, buffer, buckets);
40 RunSubtasksAndYieldImpl(buckets);
56 …ArrayView<internal::TaskBucket> buckets(MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket) * bucket… local
58 internal::DistibuteDescriptions(taskGroup, taskArray, buffer, buckets);
59 scheduler.RunTasksImpl(buckets, nullptr, false);
H A DMTScheduler.inl74 …askArray, ArrayView<internal::GroupedTask>& descriptions, ArrayView<internal::TaskBucket>& buckets) argument
78 …for (size_t bucketIndex = 0; (bucketIndex < buckets.Size()) && (index < descriptions.Size()); ++bu…
82 for (size_t i = bucketIndex; i < descriptions.Size(); i += buckets.Size())
88 …buckets[bucketIndex] = internal::TaskBucket(&descriptions[bucketStartIndex], index - bucketStartIn…
112 …ArrayView<internal::TaskBucket> buckets( MT_ALLOCATE_ON_STACK( bytesCountForTaskBuckets ), bucketC… local
114 internal::DistibuteDescriptions(group, taskArray, buffer, buckets);
115 RunTasksImpl(buckets, nullptr, false);
H A DMTFiberContext.h63 void RunSubtasksAndYieldImpl(ArrayView<internal::TaskBucket>& buckets);
H A DMTScheduler.h333 …void RunTasksImpl(ArrayView<internal::TaskBucket>& buckets, FiberContext * parentFiber, bool resto…