| /TaskScheduler/Scheduler/Source/ |
| H A D | MTFiberContext.cpp | 27 FiberContext::FiberContext() in FiberContext() function in MT::FiberContext
38 void FiberContext::SetStatus(FiberTaskStatus::Type _taskStatus) in SetStatus()
45 FiberTaskStatus::Type FiberContext::GetStatus() const in GetStatus()
50 void FiberContext::SetThreadContext(internal::ThreadContext * _threadContext) in SetThreadContext()
60 internal::ThreadContext* FiberContext::GetThreadContext() in GetThreadContext()
65 void FiberContext::Reset() in Reset()
74 void FiberContext::Yield() in Yield()
95 void FiberContext::RunSubtasksAndYieldImpl(ArrayView<internal::TaskBucket>& buckets) in RunSubtasksAndYieldImpl()
130 …void FiberContext::RunAsync(TaskGroup taskGroup, const TaskHandle* taskHandleArray, uint32 taskHan… in RunAsync()
149 …void FiberContext::RunSubtasksAndYield(TaskGroup taskGroup, const TaskHandle* taskHandleArray, uin… in RunSubtasksAndYield()
|
| H A D | MTScheduler.cpp | 63 FiberContext& context = standartFiberContexts[i]; in TaskScheduler()
75 FiberContext& context = extendedFiberContexts[i]; in TaskScheduler()
152 FiberContext* TaskScheduler::RequestFiberContext(internal::GroupedTask& task) in RequestFiberContext()
154 FiberContext *fiberContext = task.awaitingFiber; in RequestFiberContext()
191 void TaskScheduler::ReleaseFiberContext(FiberContext*&& fiberContext) in ReleaseFiberContext()
218 …FiberContext* TaskScheduler::ExecuteTask(internal::ThreadContext& threadContext, FiberContext* fib… in ExecuteTask()
274 FiberContext* parentFiberContext = fiberContext->parentFiber; in ExecuteTask()
315 FiberContext& fiberContext = *(FiberContext*)(userData); in FiberMain()
565 FiberContext* parentFiber = ExecuteTask(context, fiberContext); in SchedulerFiberProcessTask()
601 FiberContext* yieldedTask = fiberContext; in SchedulerFiberProcessTask()
[all …]
|
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTGroupedTask.h | 32 class FiberContext; variable
39 FiberContext* awaitingFiber;
40 FiberContext* parentFiber;
|
| H A D | MTScheduler.h | 113 static void TaskEntryPoint(MT::FiberContext& fiberContext, const void* userData) \
217 friend class FiberContext; variable
318 FiberContext standartFiberContexts[MT_MAX_STANDART_FIBERS_COUNT];
319 FiberContext extendedFiberContexts[MT_MAX_EXTENDED_FIBERS_COUNT];
322 LockFreeQueueMPMC<FiberContext*, MT_MAX_STANDART_FIBERS_COUNT * 2> standartFibersAvailable;
323 LockFreeQueueMPMC<FiberContext*, MT_MAX_EXTENDED_FIBERS_COUNT * 2> extendedFibersAvailable;
331 FiberContext* RequestFiberContext(internal::GroupedTask& task);
332 void ReleaseFiberContext(FiberContext*&& fiberExecutionContext);
333 …void RunTasksImpl(ArrayView<internal::TaskBucket>& buckets, FiberContext * parentFiber, bool resto…
344 …static FiberContext* ExecuteTask (internal::ThreadContext& threadContext, FiberContext* fiberConte…
|
| H A D | MTFiberContext.h | 59 class FiberContext
67 FiberContext();
113 FiberContext* parentFiber;
|
| H A D | MTThreadContext.h | 44 class FiberContext; variable
78 FiberContext* lastActiveFiberContext;
|
| H A D | MTTaskDesc.h | 34 class FiberContext; variable
35 typedef void (*TTaskEntryPoint)(FiberContext & context, const void* userData);
|
| H A D | MTScheduler.inl | 40 //template specialization for FiberContext*
42 inline internal::GroupedTask GetGroupedTask(TaskGroup group, FiberContext* const * src)
46 FiberContext* fiberContext = *src;
105 …MT_ASSERT(!IsWorkerThread(), "Can't use RunAsync inside Task. Use FiberContext.RunAsync() instead.…
|
| H A D | MTFiberContext.inl | 27 …void FiberContext::RunSubtasksAndYield(TaskGroup taskGroup, const TTask* taskArray, size_t taskCou…
44 void FiberContext::RunAsync(TaskGroup taskGroup, const TTask* taskArray, size_t taskCount)
|
| /TaskScheduler/SchedulerTests/Tests/ |
| H A D | SubtasksTests.cpp | 52 void Do(MT::FiberContext& context) in SUITE()
70 void Do(MT::FiberContext&) in SUITE()
83 void Do(MT::FiberContext&) in SUITE()
111 void Do(MT::FiberContext& context) in SUITE()
121 void Do(MT::FiberContext& context) in SUITE()
132 void Do(MT::FiberContext& context) in SUITE()
211 void Do(MT::FiberContext&) in SUITE()
225 void Do(MT::FiberContext& context) in SUITE()
243 void Do(MT::FiberContext& context) in SUITE()
|
| H A D | WaitTests.cpp | 41 void Do(MT::FiberContext&) in SUITE()
53 void Do(MT::FiberContext& ctx) in SUITE()
92 void Do(MT::FiberContext&) in SUITE()
142 void Do(MT::FiberContext&) in SUITE()
161 void Do(MT::FiberContext& ctx) in SUITE()
|
| H A D | GroupTests.cpp | 44 void Do(MT::FiberContext& ) in SUITE()
62 void Do(MT::FiberContext& ctx) in SUITE()
83 void Do(MT::FiberContext& ctx) in SUITE()
|
| H A D | StackSizeTests.cpp | 34 void Do(MT::FiberContext&) in SUITE()
52 void Do(MT::FiberContext&) in SUITE()
|
| H A D | CleanupTests.cpp | 36 void Do(MT::FiberContext&) in SUITE()
|
| H A D | SimpleTests.cpp | 40 void Do(MT::FiberContext&) in SUITE()
71 void Do(MT::FiberContext&) in SUITE()
147 void Do(MT::FiberContext& context) in SUITE()
|
| H A D | PriorityTests.cpp | 75 void Do(MT::FiberContext& ctx) in SUITE()
104 void Do(MT::FiberContext& ctx) in SUITE()
138 void Do(MT::FiberContext& ctx) in SUITE()
|
| H A D | DxtTests.cpp | 121 void Do(MT::FiberContext&) in SUITE()
200 void Do(MT::FiberContext& context) in SUITE()
276 void Do(MT::FiberContext&) in SUITE()
345 void Do(MT::FiberContext& context) in SUITE()
|
| H A D | FireAndForget.cpp | 76 void Do(MT::FiberContext& context) in SUITE()
156 void Do(MT::FiberContext&) in SUITE()
|
| /TaskScheduler/ |
| H A D | README.md | 32 void Do(MT::FiberContext&)
|