61 		for (uint32 i = 0; i < MT_MAX_STANDART_FIBERS_COUNT; i++)  in TaskScheduler()  local
63 			FiberContext& context = standartFiberContexts[i];  in TaskScheduler()
73 		for (uint32 i = 0; i < MT_MAX_EXTENDED_FIBERS_COUNT; i++)  in TaskScheduler()  local
75 			FiberContext& context = extendedFiberContexts[i];  in TaskScheduler()
88 		for (int16 i = 0; i < TaskGroup::MT_MAX_GROUPS_COUNT; i++)  in TaskScheduler()  local
90 			if (i != TaskGroup::DEFAULT)  in TaskScheduler()
92 				bool res = availableGroups.TryPush( TaskGroup(i) );  in TaskScheduler()
109 		for (int32 i = 0; i < totalThreadsCount; i++)  in TaskScheduler()  local
111 			threadContext[i].SetThreadIndex(i);  in TaskScheduler()
112 			threadContext[i].taskScheduler = this;  in TaskScheduler()
114 			uint32 threadCore = i;  in TaskScheduler()
118 				const WorkerThreadParams& params = workerParameters[i];  in TaskScheduler()
124 …threadContext[i].thread.Start( MT_SCHEDULER_STACK_SIZE, WorkerThreadMain, &threadContext[i], threa…  in TaskScheduler()
131 		for (int32 i = 0; i < totalThreadsCount; i++)  in JoinWorkerThreads()  local
133 			threadContext[i].state.Store(internal::ThreadState::EXIT);  in JoinWorkerThreads()
134 			threadContext[i].hasNewTasksEvent.Signal();  in JoinWorkerThreads()
137 		for (int32 i = 0; i < totalThreadsCount; i++)  in JoinWorkerThreads()  local
139 			threadContext[i].thread.Join();  in JoinWorkerThreads()
634 		for (size_t i = 0; i < buckets.Size(); ++i)  in RunTasksImpl()  local
636 			int bucketIndex = ((roundRobinIndex + i) % threadsCount.LoadRelaxed());  in RunTasksImpl()
653 		for (size_t i = 0; i < buckets.Size(); ++i)  in RunTasksImpl()  local
655 			internal::TaskBucket& bucket = buckets[i];  in RunTasksImpl()
679 			for (size_t i = 0; i < TaskGroup::MT_MAX_GROUPS_COUNT; i++)  in RunTasksImpl()  local
681 				int groupNewTaskCount = newTaskCountInGroup[i];  in RunTasksImpl()
684 					groupStats[i].Add((uint32)groupNewTaskCount);  in RunTasksImpl()
696 		for (size_t i = 0; i < buckets.Size(); ++i)  in RunTasksImpl()  local
701 			internal::TaskBucket& bucket = buckets[i];  in RunTasksImpl()
827 		for (int32 i = 0; i < threadsCount; i++)  in IsWorkerThread()  local
829 			if (threadContext[i].threadId.IsEqual(ThreadId::Self()))  in IsWorkerThread()
834 		for (uint32 i = 0; i < waitingThreads.size(); i++)  in IsWorkerThread()  local
836 			if (waitingThreads[i].IsEqual(ThreadId::Self()))  in IsWorkerThread()