1 write to _queue
Microsoft.ML.Data (1)
DataLoadSave\Text\TextLoaderCursor.cs (1)
914_queue = new BlockingQueue<RowBatch>(2);
3 references to _queue
Microsoft.ML.Data (3)
DataLoadSave\Text\TextLoaderCursor.cs (3)
944return _queue.GetConsumingEnumerable(); 967_queue.CompleteAdding(); 1025while (!_queue.TryAdd(batch, TimeOut))