2 writes to _queue
Microsoft.ML.Data (2)
DataLoadSave\Text\TextLoaderCursor.cs (2)
439_queue = new BlockingQueue<LineBatch>(bufSize); 461_queue = null;
7 references to _queue
Microsoft.ML.Data (7)
DataLoadSave\Text\TextLoaderCursor.cs (7)
458if (_queue != null) 460_queue.Dispose(); 467if (!_queue.TryTake(out LineBatch batch, millisecondsTimeout: -1)) 768while (!_queue.TryAdd(lines, TimeOut)) 790while (!_queue.TryAdd(new LineBatch(ex), TimeOut)) 798_queue.CompleteAdding(); 814while (!_queue.TryAdd(new LineBatch(path, total, batch, infos), TimeOut))