3 instantiations of SingleProducerSingleConsumerQueue
System.Threading.Tasks.Dataflow (3)
Internal\SourceCore.cs (1)
50private readonly SingleProducerSingleConsumerQueue<TOutput> _messages = new SingleProducerSingleConsumerQueue<TOutput>(); // protected by AddMessage/ValueLock
Internal\SpscTargetCore.cs (1)
49private readonly SingleProducerSingleConsumerQueue<TInput> _messages = new SingleProducerSingleConsumerQueue<TInput>();
Internal\TargetCore.cs (1)
125(IProducerConsumerQueue<KeyValuePair<TInput, long>>)new SingleProducerSingleConsumerQueue<KeyValuePair<TInput, long>>() :
5 references to SingleProducerSingleConsumerQueue
System.Threading.Tasks.Dataflow (5)
Internal\SourceCore.cs (1)
50private readonly SingleProducerSingleConsumerQueue<TOutput> _messages = new SingleProducerSingleConsumerQueue<TOutput>(); // protected by AddMessage/ValueLock
Internal\SpscTargetCore.cs (1)
49private readonly SingleProducerSingleConsumerQueue<TInput> _messages = new SingleProducerSingleConsumerQueue<TInput>();
src\libraries\Common\src\System\Collections\Concurrent\SingleProducerSingleConsumerQueue.cs (3)
18[DebuggerTypeProxy(typeof(SingleProducerSingleConsumerQueue<>.SingleProducerSingleConsumerQueue_DebugView))] 423private readonly SingleProducerSingleConsumerQueue<T> _queue; 427public SingleProducerSingleConsumerQueue_DebugView(SingleProducerSingleConsumerQueue<T> queue)