Home
last modified time | relevance | path

Searched refs:threadContext (Results 1 – 5 of 5) sorted by relevance

/TaskScheduler/Scheduler/Source/
H A DMTFiberContext.cpp28 : threadContext(nullptr) in FiberContext()
40 MT_ASSERT(threadContext, "Sanity check failed"); in SetStatus()
57 threadContext = _threadContext; in SetThreadContext()
62 return threadContext; in GetThreadContext()
70 threadContext = nullptr; in Reset()
78 Fiber & schedulerFiber = threadContext->schedulerFiber; in Yield()
85 threadContext = nullptr; in Yield()
97 MT_ASSERT(threadContext, "Sanity check failed!"); in RunSubtasksAndYieldImpl()
118 threadContext = nullptr; in RunSubtasksAndYieldImpl()
133 MT_ASSERT(threadContext, "ThreadContext is nullptr"); in RunAsync()
[all …]
H A DMTScheduler.cpp111 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()
134 threadContext[i].hasNewTasksEvent.Signal(); in JoinWorkerThreads()
139 threadContext[i].thread.Join(); in JoinWorkerThreads()
226 fiberContext->SetThreadContext(&threadContext); in ExecuteTask()
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()
757 waitContext.threadContext = &context; in WaitGroup()
[all …]
/TaskScheduler/Scheduler/Include/
H A DMTFiberContext.inl30 MT_ASSERT(threadContext, "ThreadContext is nullptr");
32 TaskScheduler& scheduler = *(threadContext->taskScheduler);
34 ArrayView<internal::GroupedTask> buffer(threadContext->descBuffer, taskCount);
48 MT_ASSERT(threadContext, "ThreadContext is nullptr");
49 …MT_ASSERT(threadContext->taskScheduler->IsWorkerThread(), "Can't use RunAsync outside Task. Use Ta…
51 TaskScheduler& scheduler = *(threadContext->taskScheduler);
53 ArrayView<internal::GroupedTask> buffer(threadContext->descBuffer, taskCount);
H A DMTScheduler.h288 internal::ThreadContext* threadContext; member
306 internal::ThreadContext threadContext[MT_MAX_THREAD_COUNT]; variable
342 static bool TryStealTask(internal::ThreadContext& threadContext, internal::GroupedTask & task);
344 …static FiberContext* ExecuteTask (internal::ThreadContext& threadContext, FiberContext* fiberConte…
H A DMTFiberContext.h93 internal::ThreadContext * threadContext;