Searched refs:taskScheduler (Results 1 – 5 of 5) sorted by relevance
| /TaskScheduler/Scheduler/Source/ |
| H A D | MTThreadContext.cpp | 45 , taskScheduler(nullptr) in ThreadContext()
56 , taskScheduler(nullptr) in ThreadContext()
89 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyWaitStarted()
97 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyWaitFinished()
105 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyTemporaryWorkerThreadJoin()
113 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyTemporaryWorkerThreadLeave()
121 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyTaskExecuteStateChanged()
129 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyThreadCreated()
137 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyThreadStarted()
145 if (IProfilerEventListener* eventListener = taskScheduler->GetProfilerEventListener()) in NotifyThreadStoped()
[all …]
|
| H A D | MTFiberContext.cpp | 98 MT_ASSERT(threadContext->taskScheduler, "Sanity check failed!"); in RunSubtasksAndYieldImpl()
99 …MT_ASSERT(threadContext->taskScheduler->IsWorkerThread(), "Can't use RunSubtasksAndYield outside T… in RunSubtasksAndYieldImpl()
103 threadContext->taskScheduler->RunTasksImpl(buckets, this, false); in RunSubtasksAndYieldImpl()
134 MT_ASSERT(threadContext->taskScheduler, "Sanity check failed!"); in RunAsync()
135 …MT_ASSERT(threadContext->taskScheduler->IsWorkerThread(), "Can't use RunAsync outside Task. Use Ta… in RunAsync()
137 TaskScheduler& scheduler = *(threadContext->taskScheduler); in RunAsync()
153 MT_ASSERT(threadContext->taskScheduler, "TaskScheduler is nullptr"); in RunSubtasksAndYield()
155 TaskScheduler& scheduler = *(threadContext->taskScheduler); in RunSubtasksAndYield()
|
| H A D | MTScheduler.cpp | 112 threadContext[i].taskScheduler = this; in TaskScheduler()
270 int allGroupTaskCount = threadContext.taskScheduler->allGroups.Dec(); in ExecuteTask()
343 uint32 workersCount = threadContext.taskScheduler->GetWorkersCount(); in TryStealTask()
370 MT_ASSERT(context.taskScheduler, "Task scheduler must be not null!"); in WorkerThreadMain()
393 MT_ASSERT(context.taskScheduler, "Task scheduler must be not null!"); in SchedulerFiberWait()
445 MT_ASSERT(context.taskScheduler, "Task scheduler must be not null!"); in SchedulerFiberMain()
452 context.taskScheduler->startedThreadsCount.IncFetch(); in SchedulerFiberMain()
576 context.taskScheduler->ReleaseFiberContext(std::move(fiberContext)); in SchedulerFiberProcessTask()
606 context.taskScheduler->RunTasksImpl(buckets, nullptr, true); in SchedulerFiberProcessTask()
752 context.taskScheduler = this; in WaitGroup()
[all …]
|
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTFiberContext.inl | 32 TaskScheduler& scheduler = *(threadContext->taskScheduler);
49 …MT_ASSERT(threadContext->taskScheduler->IsWorkerThread(), "Can't use RunAsync outside Task. Use Ta…
51 TaskScheduler& scheduler = *(threadContext->taskScheduler);
|
| H A D | MTThreadContext.h | 81 TaskScheduler* taskScheduler; member
|