Lines Matching refs:internal
133 threadContext[i].state.Store(internal::ThreadState::EXIT); in JoinWorkerThreads()
152 FiberContext* TaskScheduler::RequestFiberContext(internal::GroupedTask& task) in RequestFiberContext()
218 …FiberContext* TaskScheduler::ExecuteTask(internal::ThreadContext& threadContext, FiberContext* fib… in ExecuteTask()
341 …bool TaskScheduler::TryStealTask(internal::ThreadContext& threadContext, internal::GroupedTask & t… in TryStealTask()
356 internal::ThreadContext& victimContext = threadContext.taskScheduler->threadContext[index]; in TryStealTask()
369 internal::ThreadContext& context = *(internal::ThreadContext*)(userData); in WorkerThreadMain()
392 internal::ThreadContext& context = *waitContext.threadContext; in SchedulerFiberWait()
444 internal::ThreadContext& context = *(internal::ThreadContext*)(userData); in SchedulerFiberMain()
475 while(context.state.Load() != internal::ThreadState::EXIT) in SchedulerFiberMain()
506 internal::GroupedTask task; in SchedulerFiberMain()
541 …void TaskScheduler::SchedulerFiberProcessTask( internal::ThreadContext& context, internal::Grouped… in SchedulerFiberProcessTask()
598 ArrayView<internal::GroupedTask> buffer(context.descBuffer, 1); in SchedulerFiberProcessTask()
599 … ArrayView<internal::TaskBucket> buckets( MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket)), 1 ); in SchedulerFiberProcessTask()
603 …internal::DistibuteDescriptions( TaskGroup(TaskGroup::ASSIGN_FROM_CONTEXT), yieldedTasksQueue.Begi… in SchedulerFiberProcessTask()
616 bool TaskScheduler::SchedulerFiberStep( internal::ThreadContext& context, bool disableTaskStealing) in SchedulerFiberStep()
618 internal::GroupedTask task; in SchedulerFiberStep()
628 …void TaskScheduler::RunTasksImpl(ArrayView<internal::TaskBucket>& buckets, FiberContext * parentFi… in RunTasksImpl()
637 internal::ThreadContext & context = threadContext[bucketIndex]; in RunTasksImpl()
655 internal::TaskBucket& bucket = buckets[i]; in RunTasksImpl()
658 internal::GroupedTask & task = bucket.tasks[taskIndex]; in RunTasksImpl()
699 internal::ThreadContext & context = threadContext[bucketIndex]; in RunTasksImpl()
701 internal::TaskBucket& bucket = buckets[i]; in RunTasksImpl()
705 …MT_ASSERT(bucket.count < (internal::TASK_BUFFER_CAPACITY - 1), "Sanity check failed. Too many task… in RunTasksImpl()
726 …ArrayView<internal::GroupedTask> buffer(MT_ALLOCATE_ON_STACK(sizeof(internal::GroupedTask) * taskH… in RunAsync()
729 …ArrayView<internal::TaskBucket> buckets(MT_ALLOCATE_ON_STACK(sizeof(internal::TaskBucket) * bucket… in RunAsync()
731 internal::DistibuteDescriptions(group, taskHandleArray, buffer, buckets); in RunAsync()
748 …size_t bytesCountForDescBuffer = internal::ThreadContext::GetMemoryRequrementInBytesForDescBuffer(… in WaitGroup()
751 internal::ThreadContext context(descBuffer); in WaitGroup()
783 …size_t bytesCountForDescBuffer = internal::ThreadContext::GetMemoryRequrementInBytesForDescBuffer(… in WaitAll()
786 internal::ThreadContext context(descBuffer); in WaitAll()