Lines Matching refs:taskScheduler

112 			threadContext[i].taskScheduler = this;  in TaskScheduler()
259 …TaskScheduler::TaskGroupDescription & groupDesc = threadContext.taskScheduler->GetGroupDesc(taskG… in ExecuteTask()
270 int allGroupTaskCount = threadContext.taskScheduler->allGroups.Dec(); in ExecuteTask()
343 uint32 workersCount = threadContext.taskScheduler->GetWorkersCount(); in TryStealTask()
356 internal::ThreadContext& victimContext = threadContext.taskScheduler->threadContext[index]; in TryStealTask()
370 MT_ASSERT(context.taskScheduler, "Task scheduler must be not null!"); in WorkerThreadMain()
393 MT_ASSERT(context.taskScheduler, "Task scheduler must be not null!"); in SchedulerFiberWait()
403 bool isTaskStealingDisabled = context.taskScheduler->IsTaskStealingDisabled(0); in SchedulerFiberWait()
445 MT_ASSERT(context.taskScheduler, "Task scheduler must be not null!"); in SchedulerFiberMain()
451 int32 totalThreadsCount = context.taskScheduler->threadsCount.LoadRelaxed(); in SchedulerFiberMain()
452 context.taskScheduler->startedThreadsCount.IncFetch(); in SchedulerFiberMain()
457 int32 initializedThreadsCount = context.taskScheduler->startedThreadsCount.Load(); in SchedulerFiberMain()
473 bool isTaskStealingDisabled = context.taskScheduler->IsTaskStealingDisabled(); in SchedulerFiberMain()
548 FiberContext* fiberContext = context.taskScheduler->RequestFiberContext(task); in SchedulerFiberProcessTask()
576 context.taskScheduler->ReleaseFiberContext(std::move(fiberContext)); in SchedulerFiberProcessTask()
606 context.taskScheduler->RunTasksImpl(buckets, nullptr, true); in SchedulerFiberProcessTask()
752 context.taskScheduler = this; in WaitGroup()
787 context.taskScheduler = this; in WaitAll()