3 references to SingleProducerSingleConsumerQueue
System.Threading.Tasks.Dataflow (3)
Internal\SourceCore.cs (1)
50
private readonly SingleProducerSingleConsumerQueue<TOutput> _messages = new
SingleProducerSingleConsumerQueue
<TOutput>(); // protected by AddMessage/ValueLock
Internal\SpscTargetCore.cs (1)
49
private readonly SingleProducerSingleConsumerQueue<TInput> _messages = new
SingleProducerSingleConsumerQueue
<TInput>();
Internal\TargetCore.cs (1)
125
(IProducerConsumerQueue<KeyValuePair<TInput, long>>)new
SingleProducerSingleConsumerQueue
<KeyValuePair<TInput, long>>() :