Home
last modified time | relevance | path

Searched refs:ThreadId (Results 1 – 7 of 7) sorted by relevance

/TaskScheduler/Scheduler/Include/Platform/Windows/
H A DMTThread.h41 class ThreadId
47 void Assign(const ThreadId& other) in Assign()
55 ThreadId() in ThreadId() function
60 mt_forceinline ThreadId(const ThreadId& other) in ThreadId() function
65 mt_forceinline ThreadId& operator=(const ThreadId& other)
71 mt_forceinline static ThreadId Self() in Self()
73 ThreadId selfThread; in Self()
84 mt_forceinline bool IsEqual(const ThreadId& other) const in IsEqual()
/TaskScheduler/Scheduler/Include/Platform/Posix/
H A DMTThread.h67 class ThreadId
73 void Assign(const ThreadId& other) in Assign()
81 ThreadId() in ThreadId() function
86 mt_forceinline ThreadId(const ThreadId& other) in ThreadId() function
91 mt_forceinline ThreadId& operator=(const ThreadId& other)
97 mt_forceinline static ThreadId Self() in Self()
99 ThreadId selfThread; in Self()
110 mt_forceinline bool IsEqual(const ThreadId& other) const in IsEqual()
/TaskScheduler/Scheduler/Source/
H A DMTScheduler.cpp220 MT_ASSERT(threadContext.threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed"); in ExecuteTask()
283 … MT_ASSERT(threadContext.threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed"); in ExecuteTask()
372 context.threadId = ThreadId::Self(); in WorkerThreadMain()
754 context.threadId = ThreadId::Self(); in WaitGroup()
763 waitingThreads[waitingSlotIndex % waitingThreads.size()] = ThreadId::Self(); in WaitGroup()
767 waitingThreads[waitingSlotIndex % waitingThreads.size()] = ThreadId(); in WaitGroup()
789 context.threadId = ThreadId::Self(); in WaitAll()
798 waitingThreads[waitingSlotIndex % waitingThreads.size()] = ThreadId::Self(); in WaitAll()
803 waitingThreads[waitingSlotIndex % waitingThreads.size()] = ThreadId(); in WaitAll()
829 if (threadContext[i].threadId.IsEqual(ThreadId::Self())) in IsWorkerThread()
[all …]
H A DMTFiberContext.cpp41 …MT_ASSERT(threadContext->threadId.IsEqual(ThreadId::Self()), "You can change task status only from… in SetStatus()
100 …MT_ASSERT(threadContext->threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed"); in RunSubtasksAndYieldImpl()
106 …MT_ASSERT(threadContext->threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed"); in RunSubtasksAndYieldImpl()
/TaskScheduler/Scheduler/Include/
H A DMTThreadContext.h87 ThreadId threadId;
H A DMTScheduler.h300 std::array<ThreadId, 4 > waitingThreads;
/TaskScheduler/SchedulerTests/Profiler/
H A DProfiler.cpp152 Brofiler::FiberSyncData::AttachToThread(currentFiberStorage, MT::ThreadId::Self().AsUInt64()); in OnTaskExecuteStateChanged()