1 type derived from ConcurrentQueue
mscorlib (1)
system\threading\Tasks\ProducerConsumerQueues.cs (1)
71internal sealed class MultiProducerMultiConsumerQueue<T> : ConcurrentQueue<T>, IProducerConsumerQueue<T>
7 instantiations of ConcurrentQueue
mscorlib (2)
system\threading\Tasks\Parallel.cs (2)
304LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); }); 322LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); });
System (2)
sys\system\collections\concurrent\BlockingCollection.cs (2)
158: this(new ConcurrentQueue<T>()) 173: this(new ConcurrentQueue<T>(), boundedCapacity)
System.Data (2)
fx\src\data\System\Data\ProviderBase\DbConnectionPool.cs (1)
439private readonly ConcurrentQueue<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();
fx\src\data\System\Data\SqlClient\SqlAeadAes256CbcHmac256Algorithm.cs (1)
123_cryptoProviderPool = new ConcurrentQueue<AesCryptoServiceProvider>();
System.ServiceModel.Internals (1)
System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)
953static readonly ConcurrentQueue<StringBuilder> freeStringBuilders = new ConcurrentQueue<StringBuilder>();
38 references to ConcurrentQueue
mscorlib (33)
system\Collections\Concurrent\ConcurrentQueue.cs (29)
38/// All public and protected members of <see cref="ConcurrentQueue{T}"/> are thread-safe and may be used 64/// Initializes a new instance of the <see cref="ConcurrentQueue{T}"/> class. 98/// Initializes a new instance of the <see cref="ConcurrentQueue{T}"/> 102/// cref="ConcurrentQueue{T}"/>.</param> 181/// with the SyncRoot; otherwise, false. For <see cref="ConcurrentQueue{T}"/>, this property always 224/// <remarks>For <see cref="ConcurrentQueue{T}"/>, this operation will always add the object to the 225/// end of the <see cref="ConcurrentQueue{T}"/> 242/// <remarks>For <see cref="ConcurrentQueue{T}"/>, this operation will attempt to remove the object 243/// from the beginning of the <see cref="ConcurrentQueue{T}"/>. 251/// Gets a value that indicates whether the <see cref="ConcurrentQueue{T}"/> is empty. 253/// <value>true if the <see cref="ConcurrentQueue{T}"/> is empty; otherwise, false.</value> 295/// Copies the elements stored in the <see cref="ConcurrentQueue{T}"/> to a new array. 298/// cref="ConcurrentQueue{T}"/>.</returns> 305/// Copies the <see cref="ConcurrentQueue{T}"/> elements to a new <see 309/// elements copied from the <see cref="ConcurrentQueue{T}"/>.</returns> 386/// Gets the number of elements contained in the <see cref="ConcurrentQueue{T}"/>. 388/// <value>The number of elements contained in the <see cref="ConcurrentQueue{T}"/>.</value> 424/// Copies the <see cref="ConcurrentQueue{T}"/> elements to an existing one-dimensional <see 429/// <see cref="ConcurrentQueue{T}"/>. The <see cref="T:System.Array">Array</see> must have zero-based 439/// -or- The number of elements in the source <see cref="ConcurrentQueue{T}"/> is greater than the 460/// cref="ConcurrentQueue{T}"/>. 463/// cref="ConcurrentQueue{T}"/>.</returns> 571/// Adds an object to the end of the <see cref="ConcurrentQueue{T}"/>. 574/// cref="ConcurrentQueue{T}"/>. The value can be a null reference 592/// cref="ConcurrentQueue{T}"/>. 599/// cref="ConcurrentQueue{T}"/> 615/// Attempts to return an object from the beginning of the <see cref="ConcurrentQueue{T}"/> 685private volatile ConcurrentQueue<T> m_source; 690internal Segment(long index, ConcurrentQueue<T> source)
system\Collections\Concurrent\IProducerConsumerCollection.cs (1)
50/// -or- The number of elements in the source <see cref="ConcurrentQueue{T}"/> is greater than the
system\threading\Tasks\Parallel.cs (3)
278ConcurrentQueue<Exception> exceptionQ = null; // will be lazily initialized if necessary 304LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); }); 322LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); });
System (2)
sys\system\collections\concurrent\BlockingCollection.cs (2)
155/// The default underlying collection is a <see cref="System.Collections.Concurrent.ConcurrentQueue{T}">ConcurrentQueue&lt;T&gt;</see>. 170/// The default underlying collection is a <see cref="System.Collections.Concurrent.ConcurrentQueue{T}">ConcurrentQueue&lt;T&gt;</see>.
System.Data (2)
fx\src\data\System\Data\ProviderBase\DbConnectionPool.cs (1)
439private readonly ConcurrentQueue<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();
fx\src\data\System\Data\SqlClient\SqlAeadAes256CbcHmac256Algorithm.cs (1)
81private readonly ConcurrentQueue<AesCryptoServiceProvider> _cryptoProviderPool;
System.ServiceModel.Internals (1)
System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)
953static readonly ConcurrentQueue<StringBuilder> freeStringBuilders = new ConcurrentQueue<StringBuilder>();