1 type derived from ConcurrentQueue
mscorlib (1)
system\threading\Tasks\ProducerConsumerQueues.cs (1)
71
internal sealed class MultiProducerMultiConsumerQueue<T> :
ConcurrentQueue
<T>, IProducerConsumerQueue<T>
7 instantiations of ConcurrentQueue
mscorlib (2)
system\threading\Tasks\Parallel.cs (2)
304
LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new
ConcurrentQueue
<Exception>(); });
322
LazyInitializer.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)
439
private 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)
953
static 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}"/>
685
private volatile
ConcurrentQueue
<T> m_source;
690
internal 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)
278
ConcurrentQueue
<Exception> exceptionQ = null; // will be lazily initialized if necessary
304
LazyInitializer.EnsureInitialized<
ConcurrentQueue
<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); });
322
LazyInitializer.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<T></see>.
170
/// The default underlying collection is a <see cref="System.Collections.Concurrent.
ConcurrentQueue
{T}">ConcurrentQueue<T></see>.
System.Data (2)
fx\src\data\System\Data\ProviderBase\DbConnectionPool.cs (1)
439
private readonly
ConcurrentQueue
<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();
fx\src\data\System\Data\SqlClient\SqlAeadAes256CbcHmac256Algorithm.cs (1)
81
private readonly
ConcurrentQueue
<AesCryptoServiceProvider> _cryptoProviderPool;
System.ServiceModel.Internals (1)
System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)
953
static readonly
ConcurrentQueue
<StringBuilder> freeStringBuilders = new ConcurrentQueue<StringBuilder>();