20 references to BlockingCollection
System (20)
sys\system\collections\concurrent\BlockingCollection.cs (20)
805public static int AddToAny(BlockingCollection<T>[] collections, T item) 847public static int AddToAny(BlockingCollection<T>[] collections, T item, CancellationToken cancellationToken) 880public static int TryAddToAny(BlockingCollection<T>[] collections, T item) 909public static int TryAddToAny(BlockingCollection<T>[] collections, T item, TimeSpan timeout) 936public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout) 968public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout, CancellationToken cancellationToken) 990private static int TryAddToAnyCore(BlockingCollection<T>[] collections, T item, int millisecondsTimeout, CancellationToken externalCancellationToken) 1071private static int TryAddToAnyFast(BlockingCollection<T>[] collections, T item) 1097private static List<WaitHandle> GetHandles(BlockingCollection<T>[] collections, CancellationToken externalCancellationToken, bool isAddOperation, out CancellationToken[] cancellationTokens) 1186public static int TakeFromAny(BlockingCollection<T>[] collections, out T item) 1215public static int TakeFromAny(BlockingCollection<T>[] collections, out T item, CancellationToken cancellationToken) 1244public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item) 1275public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item, TimeSpan timeout) 1305public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item, int millisecondsTimeout) 1339public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item, int millisecondsTimeout, CancellationToken cancellationToken) 1362private static int TryTakeFromAnyCore(BlockingCollection<T>[] collections, out T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) 1397private static int TryTakeFromAnyCoreSlow(BlockingCollection<T>[] collections, out T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) 1722private static void ValidateCollectionsArray(BlockingCollection<T>[] collections, bool isAddOperation) 1821private BlockingCollection<T> m_blockingCollection; // The collection being viewed. 1825public SystemThreadingCollections_BlockingCollectionDebugView(BlockingCollection<T> collection)