3 implementations of IProducerConsumerCollection
System.Collections.Concurrent (2)
System\Collections\Concurrent\ConcurrentBag.cs (1)
33public class ConcurrentBag<T> : IProducerConsumerCollection<T>, IReadOnlyCollection<T>
System\Collections\Concurrent\ConcurrentStack.cs (1)
39public class ConcurrentStack<T> : IProducerConsumerCollection<T>, IReadOnlyCollection<T>
System.Private.CoreLib (1)
src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\ConcurrentQueue.cs (1)
22public class ConcurrentQueue<T> : IProducerConsumerCollection<T>, IReadOnlyCollection<T>
64 references to IProducerConsumerCollection
Aspire.Cli.Tests (4)
tests\Shared\Logging\ITestSink.cs (2)
18IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 20IProducerConsumerCollection<WriteContext> Writes { get; set; }
tests\Shared\Logging\TestSink.cs (2)
28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
Aspire.Dashboard.Components.Tests (4)
tests\Shared\Logging\ITestSink.cs (2)
18IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 20IProducerConsumerCollection<WriteContext> Writes { get; set; }
tests\Shared\Logging\TestSink.cs (2)
28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
Aspire.Dashboard.Tests (4)
tests\Shared\Logging\ITestSink.cs (2)
18IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 20IProducerConsumerCollection<WriteContext> Writes { get; set; }
tests\Shared\Logging\TestSink.cs (2)
28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
Aspire.Hosting.Testing.Tests (4)
tests\Shared\Logging\ITestSink.cs (2)
18IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 20IProducerConsumerCollection<WriteContext> Writes { get; set; }
tests\Shared\Logging\TestSink.cs (2)
28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
Aspire.Hosting.Tests (4)
tests\Shared\Logging\ITestSink.cs (2)
18IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 20IProducerConsumerCollection<WriteContext> Writes { get; set; }
tests\Shared\Logging\TestSink.cs (2)
28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
Aspire.Playground.Tests (4)
tests\Shared\Logging\ITestSink.cs (2)
18IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 20IProducerConsumerCollection<WriteContext> Writes { get; set; }
tests\Shared\Logging\TestSink.cs (2)
28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
Microsoft.AspNetCore.InternalTesting (4)
Logging\ITestSink.cs (2)
19IProducerConsumerCollection<BeginScopeContext> Scopes { get; set; } 21IProducerConsumerCollection<WriteContext> Writes { get; set; }
Logging\TestSink.cs (2)
29public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 31public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }
mscorlib (1)
src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
81[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.IProducerConsumerCollection<>))]
netstandard (1)
netstandard.cs (1)
99[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.IProducerConsumerCollection<>))]
System.Collections.Concurrent (20)
artifacts\obj\System.Collections.Concurrent\Debug\net11.0\System.Collections.Concurrent.Forwards.cs (1)
5[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.IProducerConsumerCollection<>))]
src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\IProducerConsumerCollectionDebugView.cs (2)
15private readonly IProducerConsumerCollection<T> _collection; // The collection being viewed. 21public IProducerConsumerCollectionDebugView(IProducerConsumerCollection<T> collection)
System\Collections\Concurrent\BlockingCollection.cs (11)
25/// implement <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/>. 28/// <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/> represents a collection 31/// for an <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/> instance, allowing 35/// <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/>; addition attempts to the 39/// away as an <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/>. 47private IProducerConsumerCollection<T> _collection; 168/// <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/> as its underlying data store.</summary> 176public BlockingCollection(IProducerConsumerCollection<T> collection, int boundedCapacity) 191/// <see cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/> as its underlying data store.</summary> 195public BlockingCollection(IProducerConsumerCollection<T> collection) 210private void Initialize(IProducerConsumerCollection<T> collection, int boundedCapacity, int collectionCount)
System\Collections\Concurrent\ConcurrentBag.cs (1)
86bool IProducerConsumerCollection<T>.TryAdd(T item)
System\Collections\Concurrent\ConcurrentStack.cs (5)
408/// cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/>. 411/// cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/>. The value can be a null 418bool IProducerConsumerCollection<T>.TryAdd(T item) 659/// cref="System.Collections.Concurrent.IProducerConsumerCollection{T}"/>. 669bool IProducerConsumerCollection<T>.TryTake([MaybeNullWhen(false)] out T item)
System.Private.CoreLib (14)
src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\ConcurrentQueue.cs (5)
174/// Attempts to add an object to the <see cref="IProducerConsumerCollection{T}"/>. 177/// cref="IProducerConsumerCollection{T}"/>. The value can be a null 184bool IProducerConsumerCollection<T>.TryAdd(T item) 191/// Attempts to remove and return an object from the <see cref="IProducerConsumerCollection{T}"/>. 201bool IProducerConsumerCollection<T>.TryTake([MaybeNullWhen(false)] out T item) => TryDequeue(out item);
src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\IProducerConsumerCollection.cs (7)
21/// Copies the elements of the <see cref="IProducerConsumerCollection{T}"/> to 26/// the elements copied from the <see cref="IProducerConsumerCollection{T}"/>. 44/// cref="IProducerConsumerCollection{T}"/>. 47/// cref="IProducerConsumerCollection{T}"/>.</param> 53/// Attempts to remove and return an object from the <see cref="IProducerConsumerCollection{T}"/>. 64/// Copies the elements contained in the <see cref="IProducerConsumerCollection{T}"/> to a new array. 66/// <returns>A new array containing the elements copied from the <see cref="IProducerConsumerCollection{T}"/>.</returns>
src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\IProducerConsumerCollectionDebugView.cs (2)
15private readonly IProducerConsumerCollection<T> _collection; // The collection being viewed. 21public IProducerConsumerCollectionDebugView(IProducerConsumerCollection<T> collection)