Home
last modified time | relevance | path

Searched refs:TryDequeue (Results 1 – 25 of 113) sorted by relevance

12345

/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Collections.Concurrent/
H A DConcurrentQueueTests.cs138 queue.TryDequeue (out temp); in StressTryPeekTestCase()
152 queue.TryDequeue(out value); in CountTestCase()
153 queue.TryDequeue(out value); in CountTestCase()
174 queue.TryDequeue(out value); in TryPeekTestCase()
176 queue.TryDequeue(out value); in TryPeekTestCase()
190 Assert.IsTrue(queue.TryDequeue(out value), "#2"); in TryDequeueTestCase()
191 Assert.IsTrue(queue.TryDequeue(out value), "#3"); in TryDequeueTestCase()
201 Assert.IsTrue(queue.TryDequeue(out value), "#1"); in TryDequeueEmptyTestCase()
202 Assert.IsFalse(queue.TryDequeue(out value), "#2"); in TryDequeueEmptyTestCase()
262 queue.TryDequeue (out obj); in TryDequeueReferenceTest()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/Performance/
H A DPerf.ConcurrentQueue.cs60 public void TryDequeue(bool exists) in TryDequeue() method in System.Collections.Concurrent.Tests.Perf_ConcurrentQueue
79 b.TryDequeue(out int result); in TryDequeue()
98 b.TryDequeue(out int result); in EnqueueTryDequeue()
121 while (q.TryDequeue(out _)) in ProducerConsumer_EnqueueTryDequeueFromDifferentThreads()
147 if (q.TryDequeue(out int result)) in ProducerConsumer_EnqueueTryDequeueFromDifferentThreads()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Parallel/src/System/Linq/Parallel/Merging/
H A DAsynchronousChannelMergeEnumerator.cs101 if (!_done[index] && _channels[index].TryDequeue(ref _currentElement)) in MoveNext()
129 if (!isDone && current.TryDequeue(ref _currentElement)) in MoveNextSlowPath()
149 bool dequeueResult = current.TryDequeue(ref _currentElement); in MoveNextSlowPath()
194 … if (!_done[i] && _channels[i].TryDequeue(ref _currentElement, ref channelIsDone)) in MoveNextSlowPath()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/Merging/
H A DAsynchronousChannelMergeEnumerator.cs107 if (!m_done[index] && m_channels[index].TryDequeue(ref m_currentElement)) in MoveNext()
135 if (!isDone && current.TryDequeue(ref m_currentElement)) in MoveNextSlowPath()
155 bool dequeueResult = current.TryDequeue(ref m_currentElement); in MoveNextSlowPath()
200 … if (!m_done[i] && m_channels[i].TryDequeue(ref m_currentElement, ref channelIsDone)) in MoveNextSlowPath()
/dports/devel/msbuild/msbuild-0.06/src/MSBuildTaskHost/Concurrent/
H A DConcurrentQueue.cs130 public bool TryDequeue(out T result) =>
131 _head.TryDequeue(out result) || // fast-path that operates just on the head segment
143 if (head.TryDequeue(out item)) in TryDequeueSlow()
163 if (head.TryDequeue(out item)) in TryDequeueSlow()
358 public bool TryDequeue(out T item) in TryDequeue() method in Microsoft.Build.Shared.Concurrent.ConcurrentQueue.Segment
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/
H A DConcurrentQueueTests.cs38 if (q.TryDequeue(out item)) in Concurrent_Enqueue_TryDequeue_AllItemsReceived()
77 Assert.True(q.TryDequeue(out item)); in Concurrent_Enqueue_TryPeek_TryDequeue_AllItemsSeen()
114 if (cq.TryDequeue(out item)) in MultipleProducerConsumer_AllItemsTransferred()
169 Assert.True(q.TryDequeue(out item)); in CopyTo_AllItemsCopiedAtCorrectLocation()
235 Assert.True(q.TryDequeue(out temp)); in ReferenceTypes_NulledAfterDequeue()
267 if (cq.TryDequeue(out item)) in ManySegments_ConcurrentDequeues_RemainsConsistent()
/dports/devel/embb/embb-1.0.0/examples/containers/
H A Dqueues.cc36 bool result = queue.TryDequeue(i); // fail_pop in RunQueueExample1()
45 result = queue.TryDequeue(j); // pop in RunQueueExample1()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/mscorlib/system/threading/Tasks/
H A DProducerConsumerQueues.cs50 bool TryDequeue(out T result); in TryDequeue() method
80 … bool IProducerConsumerQueue<T>.TryDequeue(out T result) { return base.TryDequeue(out result); } in TryDequeue() method in System.Threading.Tasks.MultiProducerMultiConsumerQueue
210 public bool TryDequeue(out T result) in TryDequeue() method in System.Threading.Tasks.SingleProducerSingleConsumerQueue
241 return TryDequeue(out result); // will only recur once for this dequeue operation in TryDequeueSlow()
401 while (TryDequeue(out ignored)) ; in Clear()
/dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/System/Threading/Tasks/
H A DProducerConsumerQueues.cs46 bool TryDequeue(out T result); in TryDequeue() method
76 … bool IProducerConsumerQueue<T>.TryDequeue(out T result) { return base.TryDequeue(out result); } in TryDequeue() method in System.Threading.Tasks.MultiProducerMultiConsumerQueue
207 public bool TryDequeue(out T result) in TryDequeue() method in System.Threading.Tasks.SingleProducerSingleConsumerQueue
238 return TryDequeue(out result); // will only recur once for this dequeue operation in TryDequeueSlow()
398 while (TryDequeue(out ignored)) ; in Clear()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/
H A DProducerConsumerQueues.cs52 bool TryDequeue(out T result); in TryDequeue() method
82 … bool IProducerConsumerQueue<T>.TryDequeue(out T result) { return base.TryDequeue(out result); } in TryDequeue() method in System.Threading.Tasks.MultiProducerMultiConsumerQueue
213 public bool TryDequeue(out T result) in TryDequeue() method in System.Threading.Tasks.SingleProducerSingleConsumerQueue
244 return TryDequeue(out result); // will only recur once for this dequeue operation in TryDequeueSlow()
404 while (TryDequeue(out ignored)) ; in Clear()
H A DQueuedMap.cs111 internal bool TryDequeue(out T item) in TryDequeue() method in System.Threading.Tasks.Dataflow.Internal.QueuedMap.ArrayBasedLinkedQueue
197 bool popped = _queue.TryDequeue(out item); in TryPop()
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/
H A DProducerConsumerQueues.cs51 bool TryDequeue(out T result); in TryDequeue() method
81 … bool IProducerConsumerQueue<T>.TryDequeue(out T result) { return base.TryDequeue(out result); } in TryDequeue() method in System.Threading.Tasks.MultiProducerMultiConsumerQueue
212 public bool TryDequeue(out T result) in TryDequeue() method in System.Threading.Tasks.SingleProducerSingleConsumerQueue
243 return TryDequeue(out result); // will only recur once for this dequeue operation in TryDequeueSlow()
403 while (TryDequeue(out ignored)) ; in Clear()
H A DQueuedMap.cs111 internal bool TryDequeue(out T item) in TryDequeue() method in System.Threading.Tasks.Dataflow.Internal.QueuedMap.ArrayBasedLinkedQueue
197 bool popped = _queue.TryDequeue(out item); in TryPop()
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Core/Reactive/Internal/
H A DScheduledObserver.cs76 while (_queue.TryDequeue(out next)) in Dispatch()
85 while (_queue.TryDequeue(out nop)) in Dispatch()
186 while (!_queue.TryDequeue(out next)) in Run()
264 while (_queue.TryDequeue(out nop)) in Run()
/dports/devel/embb/embb-1.0.0/containers_cpp/test/
H A Dqueue_test-inl.h190 if (!q->TryDequeue(element)) { in Run()
270 bool success = queue->TryDequeue(consumed); in QueueTestSingleProducerSingleConsumer_ThreadMethod()
299 bool success = queue->TryDequeue(dequ); in QueueTestSingleThreadEnqueueDequeue_ThreadMethod()
307 bool success = queue->TryDequeue(dequ); in QueueTestSingleThreadEnqueueDequeue_ThreadMethod()
315 bool success = queue->TryDequeue(dequ); in QueueTestSingleThreadEnqueueDequeue_ThreadMethod()
/dports/devel/godot-tools/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/
H A DGodotTaskScheduler.cs34 TryDequeue(task); in TryExecuteTaskInline()
39 protected sealed override bool TryDequeue(Task task) in TryDequeue() method in Godot.GodotTaskScheduler
/dports/devel/godot/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/
H A DGodotTaskScheduler.cs34 TryDequeue(task); in TryExecuteTaskInline()
39 protected sealed override bool TryDequeue(Task task) in TryDequeue() method in Godot.GodotTaskScheduler
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Web/Util/
H A DSubscriptionQueue.cs42 while (TryDequeue(out value)) { in FireAndComplete()
51 private bool TryDequeue(out T result) { in TryDequeue() method
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections/tests/Generic/Queue/
H A DQueue.Generic.Tests.netcoreapp.cs22 Assert.True(queue.TryDequeue(out result)); in Queue_Generic_TryDequeue_AllElements()
31 Assert.False(new Queue<T>().TryDequeue(out result)); in Queue_Generic_TryDequeue_EmptyQueue_ReturnsFalse()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/
H A DConcurrentQueue.cs214 bool IProducerConsumerCollection<T>.TryTake(out T item) => TryDequeue(out item);
675 public bool TryDequeue(out T result) =>
676 _head.TryDequeue(out result) || // fast-path that operates just on the head segment
688 if (head.TryDequeue(out item)) in TryDequeueSlow()
708 if (head.TryDequeue(out item)) in TryDequeueSlow()
919 public bool TryDequeue(out T item) in TryDequeue() method in System.Collections.Concurrent.ConcurrentQueue.Segment
/dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/System/Collections/Concurrent/
H A DLowLevelConcurrentQueue.cs620 public bool TryDequeue(out T result) =>
621 _head.TryDequeue(out result) || // fast-path that operates just on the head segment
633 if (head.TryDequeue(out item)) in TryDequeueSlow()
653 if (head.TryDequeue(out item)) in TryDequeueSlow()
864 public bool TryDequeue(out T item) in TryDequeue() method in System.Collections.Concurrent.LowLevelConcurrentQueue.Segment
/dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Common/Net30/
H A DConcurrentQueue.cs116 public bool TryDequeue (out T result) in TryDequeue() method in ServiceStack.Common.Net30.ConcurrentQueue
216 return TryDequeue (out item); in TryTake()
/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Threading.Tasks/
H A DTaskSchedulerTest.cs51 protected override bool TryDequeue (Task task) in TryDequeue() method in MonoTests.System.Threading.Tasks.TaskSchedulerTests.LazyCatScheduler
87 Assert.IsFalse (TryDequeue (null), "#1"); in TestDefaultMethod()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Immutable/tests/
H A DImmutableInterlockedTests.cs398 Assert.False(ImmutableInterlocked.TryDequeue(ref queue, out value)); in TryDequeueQueue()
402 Assert.True(ImmutableInterlocked.TryDequeue(ref queue, out value)); in TryDequeueQueue()
404 Assert.True(ImmutableInterlocked.TryDequeue(ref queue, out value)); in TryDequeueQueue()
406 Assert.False(ImmutableInterlocked.TryDequeue(ref queue, out value)); in TryDequeueQueue()
/dports/devel/msbuild/msbuild-0.06/src/Build/Collections/
H A DConcurrentQueueExtensions.cs26 … ErrorUtilities.VerifyThrow(stack.TryDequeue(out result), "Unable to dequeue from queue"); in stack.TryDequeue()

12345