System.Collections.Concurrent.BlockingCollection<T>

BlockingCollection<T>

public class BlockingCollection<T> : IEnumerable<T>, ICollection, IEnumerable, IDisposable

public int BoundedCapacity { get; }

public int Count { get; }

public bool IsAddingCompleted { get; }

public bool IsCompleted { get; }

public BlockingCollection(int upperBound)

public static int AddToAny(BlockingCollection<T>[] collections, T item)

public static int AddToAny(BlockingCollection<T>[] collections, T item, CancellationToken token)

public static int TakeFromAny(BlockingCollection<T>[] collections, out T item)

public static int TakeFromAny(BlockingCollection<T>[] collections, out T item, CancellationToken token)

public static int TryAddToAny(BlockingCollection<T>[] collections, T item)

public static int TryAddToAny(BlockingCollection<T>[] collections, T item, TimeSpan ts)

public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout)

public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout, CancellationToken token)

public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item)

public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item, TimeSpan ts)

public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item, int millisecondsTimeout)

public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item, int millisecondsTimeout, CancellationToken token)

public void Add(T item)

public void Add(T item, CancellationToken token)

public void CompleteAdding()

public void CopyTo(T[] array, int index)

public void Dispose()

protected virtual void Dispose(bool managedRes)

public T Take()

public T[] ToArray()

public bool TryAdd(T item)

public bool TryAdd(T item, TimeSpan ts)

public bool TryAdd(T item, int millisecondsTimeout)

public bool TryAdd(T item, int millisecondsTimeout, CancellationToken token)

public bool TryTake(out T item)

public bool TryTake(out T item, TimeSpan ts)

public bool TryTake(out T item, int millisecondsTimeout)

public bool TryTake(out T item, int millisecondsTimeout, CancellationToken token)