111 			threadContext[i].SetThreadIndex(i);  in TaskScheduler()
112 			threadContext[i].taskScheduler = this;  in TaskScheduler()
124 …threadContext[i].thread.Start( MT_SCHEDULER_STACK_SIZE, WorkerThreadMain, &threadContext[i], threa…  in TaskScheduler()
133 			threadContext[i].state.Store(internal::ThreadState::EXIT);  in JoinWorkerThreads()
134 			threadContext[i].hasNewTasksEvent.Signal();  in JoinWorkerThreads()
139 			threadContext[i].thread.Join();  in JoinWorkerThreads()
218 …FiberContext* TaskScheduler::ExecuteTask(internal::ThreadContext& threadContext, FiberContext* fib…  in ExecuteTask()  argument
220 		MT_ASSERT(threadContext.threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed");  in ExecuteTask()
226 		fiberContext->SetThreadContext(&threadContext);  in ExecuteTask()
237 …threadContext.NotifyTaskExecuteStateChanged( MT_SYSTEM_TASK_COLOR, MT_SYSTEM_TASK_NAME, TaskExecut…  in ExecuteTask()
241 		Fiber::SwitchTo(threadContext.schedulerFiber, fiberContext->fiber);  in ExecuteTask()
244 …threadContext.NotifyTaskExecuteStateChanged( MT_SYSTEM_TASK_COLOR, MT_SYSTEM_TASK_NAME, TaskExecut…  in ExecuteTask()
259 …TaskScheduler::TaskGroupDescription  & groupDesc = threadContext.taskScheduler->GetGroupDesc(taskG…  in ExecuteTask()
270 			int allGroupTaskCount = threadContext.taskScheduler->allGroups.Dec();  in ExecuteTask()
283 …	MT_ASSERT(threadContext.threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed");  in ExecuteTask()
287 					parentFiberContext->SetThreadContext(&threadContext);  in ExecuteTask()
341 …bool TaskScheduler::TryStealTask(internal::ThreadContext& threadContext, internal::GroupedTask & t…  in TryStealTask()  argument
343 		uint32 workersCount = threadContext.taskScheduler->GetWorkersCount();  in TryStealTask()
345 		uint32 victimIndex = threadContext.random.Get();  in TryStealTask()
350 			if (index == threadContext.workerIndex)  in TryStealTask()
356 			internal::ThreadContext& victimContext = threadContext.taskScheduler->threadContext[index];  in TryStealTask()
392 		internal::ThreadContext& context = *waitContext.threadContext;  in SchedulerFiberWait()
637 			internal::ThreadContext & context = threadContext[bucketIndex];  in RunTasksImpl()
699 			internal::ThreadContext & context = threadContext[bucketIndex];  in RunTasksImpl()
757 		waitContext.threadContext = &context;  in WaitGroup()
792 		waitContext.threadContext = &context;  in WaitAll()
829 			if (threadContext[i].threadId.IsEqual(ThreadId::Self()))  in IsWorkerThread()