2 implementations of IProducerConsumerQueue
mscorlib (2)
system\threading\Tasks\ProducerConsumerQueues.cs (2)
71internal sealed class MultiProducerMultiConsumerQueue<T> : ConcurrentQueue<T>, IProducerConsumerQueue<T> 99internal sealed class SingleProducerSingleConsumerQueue<T> : IProducerConsumerQueue<T>
9 references to IProducerConsumerQueue
mscorlib (9)
system\threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (3)
501internal readonly IProducerConsumerQueue<Task> m_tasks; 521(IProducerConsumerQueue<Task>)new SingleProducerSingleConsumerQueue<Task>() : 522(IProducerConsumerQueue<Task>)new MultiProducerMultiConsumerQueue<Task>();
system\threading\Tasks\ProducerConsumerQueues.cs (6)
75void IProducerConsumerQueue<T>.Enqueue(T item) { base.Enqueue(item); } 80bool IProducerConsumerQueue<T>.TryDequeue(out T result) { return base.TryDequeue(out result); } 83bool IProducerConsumerQueue<T>.IsEmpty { get { return base.IsEmpty; } } 86int IProducerConsumerQueue<T>.Count { get { return base.Count; } } 90int IProducerConsumerQueue<T>.GetCountSafe(object syncObj) { return base.Count; } 461int IProducerConsumerQueue<T>.GetCountSafe(object syncObj)