25 references to Token
Microsoft.ML.Core (1)
Utilities\ThreadUtils.cs (1)
170/// <see cref="Token"/> as the cancellation token (this token is canceled iff <see cref="Set"/>
Microsoft.ML.Data (24)
DataLoadSave\Binary\BinaryLoader.cs (18)
1366Contracts.Assert(ex.CancellationToken == _exMarshaller.Token); 1574_toDecompressEnumerator = _toDecompress.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator(); 1577_toReadEnumerator = _toRead.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator(); 1587_toDecompress.Add(block, ExMarshaller.Token); 1593_toDecompress.Add(sentBlock, ExMarshaller.Token); 1610_waiter.Wait(block.BlockSequence, ExMarshaller.Token); 1618_waiter.Wait(block.BlockSequence, ExMarshaller.Token); 1623_waiter.Wait(block.BlockSequence, ExMarshaller.Token); 1624_toRead.Add(block, ExMarshaller.Token); 1798_toDecompressEnumerator = _toDecompress.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator(); 1800_toReadEnumerator = _toRead.GetConsumingEnumerable(ExMarshaller.Token).GetEnumerator(); 1821_toDecompress.Add(block, ExMarshaller.Token); 1827_toDecompress.Add(sentBlock, ExMarshaller.Token); 1867_waiter.Wait(block.BlockSequence, ExMarshaller.Token); 1882_waiter.Wait(block.BlockSequence, ExMarshaller.Token); 1900_waiter.Wait(block.BlockSequence, ExMarshaller.Token); 1902_toRead.Add(new ReaderContainer(reader, decomp, block.Rows, block.BlockSequence), ExMarshaller.Token); 1989Contracts.Assert(ex.CancellationToken == _exMarshaller.Token);
DataLoadSave\Binary\BinarySaver.cs (6)
222foreach (Block block in toCompress.GetConsumingEnumerable(exMarshaller.Token)) 237waiter.Wait((long)columns * block.BlockIndex + block.ColumnIndex, exMarshaller.Token); 238toWrite.Add(new Block(compressed, block.ColumnIndex, block.BlockIndex, uncompLength), exMarshaller.Token); 423foreach (Block block in toWrite.GetConsumingEnumerable(exMarshaller.Token)) 608toCompress.Add(new Block(pipes[c].EndBlock(), c, blockIndex), exMarshaller.Token); 620toCompress.Add(new Block(pipes[c].EndBlock(), c, blockIndex), exMarshaller.Token);