/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Collections.Concurrent/ |
H A D | ConcurrentQueueTests.cs | 138 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 D | Perf.ConcurrentQueue.cs | 60 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 D | AsynchronousChannelMergeEnumerator.cs | 101 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 D | AsynchronousChannelMergeEnumerator.cs | 107 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 D | ConcurrentQueue.cs | 130 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 D | ConcurrentQueueTests.cs | 38 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 D | queues.cc | 36 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 D | ProducerConsumerQueues.cs | 50 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 D | ProducerConsumerQueues.cs | 46 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 D | ProducerConsumerQueues.cs | 52 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 D | QueuedMap.cs | 111 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 D | ProducerConsumerQueues.cs | 51 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 D | QueuedMap.cs | 111 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 D | ScheduledObserver.cs | 76 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 D | queue_test-inl.h | 190 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 D | GodotTaskScheduler.cs | 34 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 D | GodotTaskScheduler.cs | 34 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 D | SubscriptionQueue.cs | 42 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 D | Queue.Generic.Tests.netcoreapp.cs | 22 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 D | ConcurrentQueue.cs | 214 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 D | LowLevelConcurrentQueue.cs | 620 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 D | ConcurrentQueue.cs | 116 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 D | TaskSchedulerTest.cs | 51 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 D | ImmutableInterlockedTests.cs | 398 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 D | ConcurrentQueueExtensions.cs | 26 … ErrorUtilities.VerifyThrow(stack.TryDequeue(out result), "Unable to dequeue from queue"); in stack.TryDequeue()
|