Home
last modified time | relevance | path

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

/TaskScheduler/SchedulerTests/Tests/
H A DFoundationTests.cpp98 MT::LockFreeQueueMPMC<int, 32> queue; in SUITE() local
115 bool res = queue.TryPop(val); in SUITE()
127 CHECK_EQUAL(true, queue.TryPush( 113 )); in SUITE()
128 CHECK_EQUAL(true, queue.TryPush( 114 )); in SUITE()
132 CHECK_EQUAL(true, queue.TryPop(v)); in SUITE()
139 CHECK_EQUAL(true, queue.TryPop(v)); in SUITE()
141 CHECK_EQUAL(true, queue.TryPop(v)); in SUITE()
143 CHECK_EQUAL(true, queue.TryPop(v)); in SUITE()
145 CHECK_EQUAL(true, queue.TryPop(v)); in SUITE()
147 CHECK_EQUAL(true, queue.TryPop(v)); in SUITE()
[all …]
/TaskScheduler/Scheduler/Include/
H A DMTTaskQueue.h245 Queue& queue = queues[i]; in Add() local
246 if (!queue.HasSpace(count)) in Add()
260 Queue& queue = queues[queueIndex]; in Add() local
261 bool res = queue.Add(itemArray[i]); in Add()
275 Queue& queue = queues[queueIndex]; in TryPopOldest() local
276 if (queue.TryPopOldest(item)) in TryPopOldest()
289 Queue& queue = queues[queueIndex]; in TryPopNewest() local
290 if (queue.TryPopNewest(item)) in TryPopNewest()
H A DMTThreadContext.h93 TaskQueue<internal::GroupedTask, TASK_BUFFER_CAPACITY> queue; member
/TaskScheduler/Scheduler/Source/
H A DMTThreadContext.cpp57 , queue(DummyQueueFlag::IS_DUMMY_QUEUE) in ThreadContext()
H A DMTScheduler.cpp357 if (victimContext.queue.TryPopNewest(task)) in TryStealTask()
507 if ( context.queue.TryPopOldest(task) ) in SchedulerFiberMain()
619 …if ( context.queue.TryPopOldest(task) || (disableTaskStealing == false && TryStealTask(context, ta… in SchedulerFiberStep()
707 bool res = context.queue.Add(bucket.tasks, bucket.count); in RunTasksImpl()