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