IProducerConsumerCollection

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>

src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\ConcurrentQueue.cs (1)

22public class ConcurrentQueue<T> : IProducerConsumerCollection<T>, IReadOnlyCollection<T>

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); }

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); }

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); }

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); }

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); }

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); }

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); }

src\libraries\shims\mscorlib\ref\mscorlib.cs (1)

81[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.IProducerConsumerCollection<>))]

netstandard.cs (1)

99[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.IProducerConsumerCollection<>))]

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)

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)