9 references to BlockingCollection
Microsoft.AspNetCore.HttpLogging (1)
FileLoggerProcessor.cs (1)
28
private readonly BlockingCollection<string> _messageQueue = new
BlockingCollection
<string>(_maxQueuedMessages);
Microsoft.ML.Data (8)
Data\DataViewUtils.cs (2)
364
var toConsume = new
BlockingCollection
<Batch>(toConsumeBound);
552
var toConsume = new
BlockingCollection
<Batch>(toConsumeBound);
DataLoadSave\Binary\BinaryLoader.cs (4)
1570
_toDecompress = new
BlockingCollection
<Block>(_bufferSize);
1576
_toRead = new
BlockingCollection
<Block>(bufferSize);
1797
_toDecompress = new
BlockingCollection
<CompressedBlock>(_bufferSize);
1799
_toRead = new
BlockingCollection
<ReaderContainer>(bufferSize);
DataLoadSave\Binary\BinarySaver.cs (2)
655
var toWrite = new
BlockingCollection
<Block>(16);
656
var toCompress = new
BlockingCollection
<Block>(16);