Lines Matching refs:int32
103 int32 totalThreadsCount = GetWorkersCount(); in TaskScheduler()
109 for (int32 i = 0; i < totalThreadsCount; i++) in TaskScheduler()
130 int32 totalThreadsCount = GetWorkersCount(); in JoinWorkerThreads()
131 for (int32 i = 0; i < totalThreadsCount; i++) in JoinWorkerThreads()
137 for (int32 i = 0; i < totalThreadsCount; i++) in JoinWorkerThreads()
324 …k.debugColor, fiberContext.currentTask.debugID, TaskExecuteState::START, (int32)fiberContext.fiber… in FiberMain()
332 …sk.debugColor, fiberContext.currentTask.debugID, TaskExecuteState::STOP, (int32)fiberContext.fiber… in FiberMain()
419 int32 groupTaskCount = waitContext.waitCounter->Load(); in SchedulerFiberWait()
451 int32 totalThreadsCount = context.taskScheduler->threadsCount.LoadRelaxed(); in SchedulerFiberMain()
457 int32 initializedThreadsCount = context.taskScheduler->startedThreadsCount.Load(); in SchedulerFiberMain()
633 int32 roundRobinIndex = roundRobinThreadIndex.LoadRelaxed(); in RunTasksImpl()
742 int32 taskCount = groupDesc.GetTaskCount(); in WaitGroup()
762 int32 waitingSlotIndex = nextWaitingThreadSlotIndex.IncFetch(); in WaitGroup()
777 int32 taskCount = allGroups.GetTaskCount(); in WaitAll()
797 int32 waitingSlotIndex = nextWaitingThreadSlotIndex.IncFetch(); in WaitAll()
810 if (threadsCount.LoadRelaxed() <= (int32)minWorkersCount) in IsTaskStealingDisabled()
818 int32 TaskScheduler::GetWorkersCount() const in GetWorkersCount()
826 int32 threadsCount = GetWorkersCount(); in IsWorkerThread()
827 for (int32 i = 0; i < threadsCount; i++) in IsWorkerThread()