4 writes to _threads
Microsoft.ML.Data (4)
DataLoadSave\Binary\BinaryLoader.cs (4)
783_threads = Math.Max(1, args.Threads ?? (Environment.ProcessorCount / 2)); 844_threads = ctx.Reader.ReadInt32(); 849_threads = Math.Max(1, Environment.ProcessorCount / 2); 857_threads = Math.Max(1, Environment.ProcessorCount / 2);
6 references to _threads
Microsoft.ML.Data (6)
DataLoadSave\Binary\BinaryLoader.cs (6)
845ch.CheckDecode(_threads >= 0); 846if (_threads == 0) 946_host.Assert(_threads >= 1); 947SaveParameters(ctx, _autodeterminedThreads ? 0 : _threads, _shuffleBlocks); 1301int pipeBuffers = 2 * ((_parent._threads + _pipes.Length - 1) / _pipes.Length); 1383Task[] pipeWorkers = new Task[_parent._threads];