Implemented interface member:
method
TryDequeue
System.Collections.Concurrent.IProducerConsumerQueue<T>.TryDequeue(out T)
7 references to TryDequeue
System.Threading.Tasks.Dataflow (7)
Internal\SourceCore.cs (3)
185!_messages.TryDequeue(out consumedMessageValue)) 339while (_messages.TryDequeue(out item)) tmpList.Add(item); 620!_messages.TryDequeue(out dropped)) // remove the next message
Internal\SpscTargetCore.cs (2)
213_messages.TryDequeue(out nextMessage)) 327while (_messages.TryDequeue(out _)) ;
src\libraries\Common\src\System\Collections\Concurrent\SingleProducerSingleConsumerQueue.cs (2)
187TryDequeue(out result); // will only recur once for this operation 292while (TryDequeue(out _)) ;