_boundedCapacity | System.Collections.Concurrent.BlockingCollection< T > | private |
_collection | System.Collections.Concurrent.BlockingCollection< T > | private |
_consumersCancellationTokenSource | System.Collections.Concurrent.BlockingCollection< T > | private |
_currentAdders | System.Collections.Concurrent.BlockingCollection< T > | private |
_freeNodes | System.Collections.Concurrent.BlockingCollection< T > | private |
_isDisposed | System.Collections.Concurrent.BlockingCollection< T > | private |
_occupiedNodes | System.Collections.Concurrent.BlockingCollection< T > | private |
_producersCancellationTokenSource | System.Collections.Concurrent.BlockingCollection< T > | private |
Add(T item) | System.Collections.Concurrent.BlockingCollection< T > | inline |
Add(T item, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inline |
AddToAny(BlockingCollection< T >[] collections, T item) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
AddToAny(BlockingCollection< T >[] collections, T item, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
BlockingCollection() | System.Collections.Concurrent.BlockingCollection< T > | inline |
BlockingCollection(int boundedCapacity) | System.Collections.Concurrent.BlockingCollection< T > | inline |
BlockingCollection(IProducerConsumerCollection< T > collection, int boundedCapacity) | System.Collections.Concurrent.BlockingCollection< T > | inline |
BlockingCollection(IProducerConsumerCollection< T > collection) | System.Collections.Concurrent.BlockingCollection< T > | inline |
BoundedCapacity | System.Collections.Concurrent.BlockingCollection< T > | |
CancelWaitingConsumers() | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
CancelWaitingProducers() | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
CheckDisposed() | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
CompleteAdding() | System.Collections.Concurrent.BlockingCollection< T > | inline |
CopyTo(T[] array, int index) | System.Collections.Concurrent.BlockingCollection< T > | inline |
CopyTo(Array array, int index) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
Count | System.Collections.Concurrent.BlockingCollection< T > | |
Dispose() | System.Collections.Concurrent.BlockingCollection< T > | inline |
Dispose(bool disposing) | System.Collections.Concurrent.BlockingCollection< T > | inlineprotectedvirtual |
GetConsumingEnumerable() | System.Collections.Concurrent.BlockingCollection< T > | inline |
GetConsumingEnumerable(CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inline |
GetEnumerator() | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
GetEnumerator() | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
GetHandles(BlockingCollection< T >[] collections, CancellationToken externalCancellationToken, bool isAddOperation, out CancellationToken[] cancellationTokens) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
Initialize(IProducerConsumerCollection< T > collection, int boundedCapacity, int collectionCount) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
IsAddingCompleted | System.Collections.Concurrent.BlockingCollection< T > | |
IsCompleted | System.Collections.Concurrent.BlockingCollection< T > | |
IsSynchronized | System.Collections.Concurrent.BlockingCollection< T > | private |
SyncRoot | System.Collections.Concurrent.BlockingCollection< T > | private |
Take() | System.Collections.Concurrent.BlockingCollection< T > | inline |
Take(CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TakeFromAny(BlockingCollection< T >[] collections, out T? item) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TakeFromAny(BlockingCollection< T >[] collections, out T? item, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
ToArray() | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryAdd(T item) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryAdd(T item, TimeSpan timeout) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryAdd(T item, int millisecondsTimeout) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryAdd(T item, int millisecondsTimeout, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryAddToAny(BlockingCollection< T >[] collections, T item) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryAddToAny(BlockingCollection< T >[] collections, T item, TimeSpan timeout) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryAddToAny(BlockingCollection< T >[] collections, T item, int millisecondsTimeout) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryAddToAny(BlockingCollection< T >[] collections, T item, int millisecondsTimeout, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryAddToAnyCore(BlockingCollection< T >[] collections, T item, int millisecondsTimeout, CancellationToken externalCancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
TryAddToAnyFast(BlockingCollection< T >[] collections, T item) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
TryAddWithNoTimeValidation(T item, int millisecondsTimeout, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
TryTake([MaybeNullWhen(false)] out T item) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryTake([MaybeNullWhen(false)] out T item, TimeSpan timeout) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryTake([MaybeNullWhen(false)] out T item, int millisecondsTimeout) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryTake([MaybeNullWhen(false)] out T item, int millisecondsTimeout, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inline |
TryTakeFromAny(BlockingCollection< T >[] collections, out T? item) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryTakeFromAny(BlockingCollection< T >[] collections, out T? item, TimeSpan timeout) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryTakeFromAny(BlockingCollection< T >[] collections, out T? item, int millisecondsTimeout) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryTakeFromAny(BlockingCollection< T >[] collections, out T? item, int millisecondsTimeout, CancellationToken cancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlinestatic |
TryTakeFromAnyCore(BlockingCollection< T >[] collections, out T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
TryTakeFromAnyCoreSlow(BlockingCollection< T >[] collections, out T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
TryTakeWithNoTimeValidation([MaybeNullWhen(false)] out T item, int millisecondsTimeout, CancellationToken cancellationToken, CancellationTokenSource combinedTokenSource) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivate |
UpdateTimeOut(uint startTime, int originalWaitMillisecondsTimeout) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
ValidateCollectionsArray(BlockingCollection< T >[] collections, bool isAddOperation) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
ValidateMillisecondsTimeout(int millisecondsTimeout) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |
ValidateTimeout(TimeSpan timeout) | System.Collections.Concurrent.BlockingCollection< T > | inlineprivatestatic |