203public BlockingCollection<(LogLevel Level, string Message, object? State)> Logs { get; } = new();

41_stdoutLines = new BlockingCollection<string>();

28private readonly BlockingCollection<string> _messageQueue = new BlockingCollection<string>(_maxQueuedMessages);

41_stdoutLines = new BlockingCollection<string>();

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

579private BlockingCollection<INodePacket> _packetWriteQueue = new BlockingCollection<INodePacket>();

1445private readonly BlockingCollection<Task> _tasks = new BlockingCollection<Task>();

723var obj = new BlockingCollection<int>();

22private BlockingCollection<string> _stdoutLines = new BlockingCollection<string>();

41_stdoutLines = new BlockingCollection<string>();

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

158new BlockingCollection<LogMessage>(new ConcurrentQueue<LogMessage>()) : 159new BlockingCollection<LogMessage>(new ConcurrentQueue<LogMessage>(), _queueSize.Value);

92 new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();

32var hosts = new BlockingCollection<Tuple<IHost, int>>(); 95var hosts = new BlockingCollection<Tuple<IHost, int>>();

364var toConsume = new BlockingCollection<Batch>(toConsumeBound); 552var toConsume = new BlockingCollection<Batch>(toConsumeBound);

1570_toDecompress = new BlockingCollection<Block>(_bufferSize); 1576_toRead = new BlockingCollection<Block>(bufferSize); 1797_toDecompress = new BlockingCollection<CompressedBlock>(_bufferSize); 1799_toRead = new BlockingCollection<ReaderContainer>(bufferSize);

655var toWrite = new BlockingCollection<Block>(16); 656var toCompress = new BlockingCollection<Block>(16);

179new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();

41_stdoutLines = new BlockingCollection<string>();

124var logOutput = new BlockingCollection<string>();

41_stdoutLines = new BlockingCollection<string>();

124var logOutput = new BlockingCollection<string>();

41_stdoutLines = new BlockingCollection<string>();

124var logOutput = new BlockingCollection<string>();

41_stdoutLines = new BlockingCollection<string>();

124var logOutput = new BlockingCollection<string>();

41_stdoutLines = new BlockingCollection<string>();

269new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();

203public BlockingCollection<(LogLevel Level, string Message, object? State)> Logs { get; } = new();

30private BlockingCollection<string> _stdoutLines;

28private readonly BlockingCollection<string> _messageQueue = new BlockingCollection<string>(_maxQueuedMessages);

30private BlockingCollection<string> _stdoutLines;

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

579private BlockingCollection<INodePacket> _packetWriteQueue = new BlockingCollection<INodePacket>();

1445private readonly BlockingCollection<Task> _tasks = new BlockingCollection<Task>();

723var obj = new BlockingCollection<int>();

22private BlockingCollection<string> _stdoutLines = new BlockingCollection<string>();

30private BlockingCollection<string> _stdoutLines;

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

26private BlockingCollection<LogMessage> _messageQueue;

91 private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> _mQueue =

32var hosts = new BlockingCollection<Tuple<IHost, int>>(); 95var hosts = new BlockingCollection<Tuple<IHost, int>>();

364var toConsume = new BlockingCollection<Batch>(toConsumeBound); 552var toConsume = new BlockingCollection<Batch>(toConsumeBound); 1005private readonly BlockingCollection<Batch> _batchInputs; 1028OutPipe[] pipes, BlockingCollection<Batch> batchInputs, Action quitAction)

1507private readonly BlockingCollection<Block> _toDecompress; 1509private readonly BlockingCollection<Block> _toRead; 1688private readonly BlockingCollection<CompressedBlock> _toDecompress; 1690private readonly BlockingCollection<ReaderContainer> _toRead;

211private void CompressionWorker(BlockingCollection<Block> toCompress, BlockingCollection<Block> toWrite, int columns, OrderedWaiter waiter, 396private void WriteWorker(Stream stream, BlockingCollection<Block> toWrite, ColumnCodec[] activeColumns, 570private void FetchWorker(BlockingCollection<Block> toCompress, IDataView data, 655var toWrite = new BlockingCollection<Block>(16); 656var toCompress = new BlockingCollection<Block>(16);

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

178private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> _queue =

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

30/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> is used as a wrapper 33/// a <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> can be created to enforce 37/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> is similar to a traditional 60/// <summary>Gets the bounded capacity of this <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</summary> 63/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 73/// <summary>Gets whether this <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked as complete for adding.</summary> 76/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 86/// <summary>Gets whether this <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked as complete for adding and is empty.</summary> 89/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 99/// <summary>Gets the number of items contained in the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>.</summary> 100/// <value>The number of items contained in the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>.</value> 102/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 114/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 140/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> 152/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> 166/// <summary>Initializes a new instance of the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> 189/// <summary>Initializes a new instance of the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> 236/// Adds the item to the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 240/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked 243/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 247/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> was initialized, 262/// Adds the item to the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 270/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked 273/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 277/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> was initialized, 292/// Attempts to add the specified item to the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 297/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked 300/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 308/// Attempts to add the specified item to the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 317/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked 320/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 332/// Attempts to add the specified item to the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 340/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked 343/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 354/// Attempts to add the specified item to the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 366/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been marked 369/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 499/// <summary>Takes an item from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>.</summary> 502/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 505/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance, or the <see 506/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> is empty and has been marked 521/// <summary>Takes an item from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>.</summary> 526/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 529/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance, or the <see 530/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> is empty and has been marked 546/// Attempts to remove an item from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 551/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 554/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 561/// Attempts to remove an item from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 570/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 576/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 584/// Attempts to remove an item from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 592/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 597/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 605/// Attempts to remove an item from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/>. 617/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 622/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 737/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 748/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 754/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances were initialized, 758public static int AddToAny(BlockingCollection<T>[] collections, T item) 775/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 790/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 796/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances were initialized, 800public static int AddToAny(BlockingCollection<T>[] collections, T item, CancellationToken cancellationToken) 817/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 829/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 833public static int TryAddToAny(BlockingCollection<T>[] collections, T item) 840/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 855/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 862public static int TryAddToAny(BlockingCollection<T>[] collections, T item, TimeSpan timeout) 870/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 883/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 889public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout) 897/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 915/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 921public static int TryAddToAny(BlockingCollection<T>[] collections, T item, int millisecondsTimeout, CancellationToken cancellationToken) 943private static int TryAddToAnyCore(BlockingCollection<T>[] collections, T item, int millisecondsTimeout, CancellationToken externalCancellationToken) 1022private static int TryAddToAnyFast(BlockingCollection<T>[] collections, T item) 1048private static List<WaitHandle> GetHandles(BlockingCollection<T>[] collections, CancellationToken externalCancellationToken, bool isAddOperation, out CancellationToken[] cancellationTokens) 1060BlockingCollection<T> c = collections[i]; 1118/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 1129/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 1132/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 1136public static int TakeFromAny(BlockingCollection<T>[] collections, out T? item) 1143/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 1158/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 1161/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 1165public static int TakeFromAny(BlockingCollection<T>[] collections, out T? item, CancellationToken cancellationToken) 1175/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 1186/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 1189/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 1193public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T? item) 1200/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 1214/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 1220/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 1224public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T? item, TimeSpan timeout) 1232/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 1245/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 1250/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 1254public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T? item, int millisecondsTimeout) 1262/// <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances. 1279/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances has been disposed.</exception> 1284/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance.</exception> 1288public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T? item, int millisecondsTimeout, CancellationToken cancellationToken) 1311private static int TryTakeFromAnyCore(BlockingCollection<T>[] collections, out T? item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) 1345private static int TryTakeFromAnyCoreSlow(BlockingCollection<T>[] collections, out T? item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) 1428/// Marks the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instances 1436/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1488/// Releases resources used by the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance. 1497/// Releases resources used by the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance. 1511/// <summary>Copies the items from the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance into a new array.</summary> 1514/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1524/// <summary>Copies all of the items in the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance 1528/// the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance. The array must have zero-based indexing.</param> 1536/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1542/// <summary>Copies all of the items in the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance 1546/// the <see cref="System.Collections.Concurrent.BlockingCollection{T}"/> instance. The array must have zero-based indexing.</param> 1555/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1597/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1610/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1629/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1639/// cref="System.Collections.Concurrent.BlockingCollection{T}"/> has been disposed.</exception> 1653private static void ValidateCollectionsArray(BlockingCollection<T>[] collections, bool isAddOperation) 1733private readonly BlockingCollection<T> _blockingCollection; // The collection being viewed. 1737public BlockingCollectionDebugView(BlockingCollection<T> collection)

30private BlockingCollection<string> _stdoutLines;

124var logOutput = new BlockingCollection<string>();

30private BlockingCollection<string> _stdoutLines;

124var logOutput = new BlockingCollection<string>();

30private BlockingCollection<string> _stdoutLines;

124var logOutput = new BlockingCollection<string>();

30private BlockingCollection<string> _stdoutLines;

124var logOutput = new BlockingCollection<string>();

30private BlockingCollection<string> _stdoutLines;

268private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> _queue =

41public static async ValueTask<T> TakeAsync<T>(this BlockingCollection<T> collection, TimeSpan? pollTimeSpan = null, CancellationToken cancellationToken = default)