6 instantiations of OrderedWaiter
Microsoft.ML.Data (6)
DataLoadSave\Binary\BinaryLoader.cs (2)
1578_waiter = new OrderedWaiter(); 1801_waiter = new OrderedWaiter();
DataLoadSave\Binary\BinarySaver.cs (1)
666OrderedWaiter waiter = _deterministicBlockOrder ? new OrderedWaiter() : null;
DataLoadSave\Text\TextLoaderCursor.cs (2)
909_waiterReading = new OrderedWaiter(firstCleared: false); 910_waiterPublish = new OrderedWaiter(firstCleared: false);
DataView\CacheDataView.cs (1)
351waiter = new OrderedWaiter(firstCleared: false);
23 references to OrderedWaiter
Microsoft.ML.Data (23)
DataLoadSave\Binary\BinaryLoader.cs (2)
1513private readonly OrderedWaiter _waiter; 1695private readonly OrderedWaiter _waiter;
DataLoadSave\Binary\BinarySaver.cs (2)
211private void CompressionWorker(BlockingCollection<Block> toCompress, BlockingCollection<Block> toWrite, int columns, OrderedWaiter waiter, 666OrderedWaiter waiter = _deterministicBlockOrder ? new OrderedWaiter() : null;
DataLoadSave\Text\TextLoaderCursor.cs (2)
875private readonly OrderedWaiter _waiterReading; 876private readonly OrderedWaiter _waiterPublish;
DataView\CacheDataView.cs (17)
68private volatile OrderedWaiter _cacheDefaultWaiter; 334OrderedWaiter waiter; 382private void Filler(DataViewRowCursor cursor, ColumnCache[] caches, OrderedWaiter waiter) 649private readonly OrderedWaiter[] _waiters; 667HashSet<OrderedWaiter> waiters = new HashSet<OrderedWaiter>(); 672var waiter = _parent._caches[c].Waiter; 682_waiters = new OrderedWaiter[waiters.Count]; 688foreach (var w in _waiters) 1252private OrderedWaiter _waiter; 1261public OrderedWaiter Waiter { get { return _waiter; } } 1263protected ColumnCache(IExceptionContext ctx, OrderedWaiter waiter) 1279public static ColumnCache Create(CacheDataView parent, DataViewRowCursor input, int srcCol, OrderedWaiter waiter) 1299new Type[] { typeof(CacheDataView), typeof(DataViewRowCursor), typeof(int), typeof(OrderedWaiter) }, null); 1347public ImplVec(CacheDataView parent, DataViewRowCursor input, int srcCol, OrderedWaiter waiter) 1430public ImplOne(CacheDataView parent, DataViewRowCursor input, int srcCol, OrderedWaiter waiter) 1465public ColumnCache(CacheDataView parent, DataViewRowCursor input, int srcCol, OrderedWaiter waiter)