System.Collections.Concurrent.BlockingCollection<T>
public class BlockingCollection<T> : IEnumerable<T>, IEnumerable, IReadOnlyCollection<T>, ICollection, IDisposable
public BlockingCollection()
public static int AddToAny(BlockingCollection<T>[] collections, T item, CancellationToken cancellationToken)
public static int TakeFromAny(BlockingCollection<T>[] collections, out T item, CancellationToken cancellationToken)
public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout, CancellationToken cancellationToken)
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 cancellationToken)