36 …TaskScheduler::TaskScheduler(uint32 workerThreadsCount, WorkerThreadParams* workerParameters, IPro…  in TaskScheduler()
38 …TaskScheduler::TaskScheduler(uint32 workerThreadsCount, WorkerThreadParams* workerParameters, Task…  in TaskScheduler()
51 …threadsCount.StoreRelaxed( MT::Clamp(workerThreadsCount, (uint32)1, (uint32)MT_MAX_THREAD_COUNT) );  in TaskScheduler()
55 …threadsCount.StoreRelaxed( (uint32)MT::Clamp(Thread::GetNumberOfHardwareThreads() - 1, 1, (int)MT_…  in TaskScheduler()
58 		uint32 fiberIndex = 0;  in TaskScheduler()
61 		for (uint32 i = 0; i < MT_MAX_STANDART_FIBERS_COUNT; i++)  in TaskScheduler()
73 		for (uint32 i = 0; i < MT_MAX_EXTENDED_FIBERS_COUNT; i++)  in TaskScheduler()
114 			uint32 threadCore = i;  in TaskScheduler()
343 		uint32 workersCount = threadContext.taskScheduler->GetWorkersCount();  in TryStealTask()
345 		uint32 victimIndex = threadContext.random.Get();  in TryStealTask()
347 		for (uint32 attempt = 0; attempt < workersCount; attempt++)  in TryStealTask()
349 			uint32 index = victimIndex % workersCount;  in TryStealTask()
684 					groupStats[i].Add((uint32)groupNewTaskCount);  in RunTasksImpl()
689 			allGroups.Add((uint32)count);  in RunTasksImpl()
722 …void TaskScheduler::RunAsync(TaskGroup group, const TaskHandle* taskHandleArray, uint32 taskHandle…  in RunAsync()
728 		uint32 bucketCount = MT::Min((uint32)GetWorkersCount(), taskHandleCount);  in RunAsync()
735 	bool TaskScheduler::WaitGroup(TaskGroup group, uint32 milliseconds)  in WaitGroup()
772 	bool TaskScheduler::WaitAll(uint32 milliseconds)  in WaitAll()
808 	bool TaskScheduler::IsTaskStealingDisabled(uint32 minWorkersCount) const  in IsTaskStealingDisabled()
834 		for (uint32 i = 0; i < waitingThreads.size(); i++)  in IsWorkerThread()
894 	void TaskScheduler::NotifyFibersCreated(uint32 fibersCount)  in NotifyFibersCreated()
902 	void TaskScheduler::NotifyThreadsCreated(uint32 threadsCount)  in NotifyThreadsCreated()