1 write to _bufferIndex
System.Linq.Parallel (1)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
236_bufferIndex = new Shared<int>(-1);
14 references to _bufferIndex
System.Linq.Parallel (14)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (14)
243Debug.Assert(_buffer != null && _bufferIndex != null); 246if (_count == 0 || _bufferIndex.Value >= _buffer.Count - 1) 252++_bufferIndex.Value; 253currentElement = _buffer[_bufferIndex.Value].First; 254currentKey = _buffer[_bufferIndex.Value].Second; 258|| _keyComparer.Compare(_buffer[_bufferIndex.Value].Second, _sharedIndices.MaxValue) <= 0; 275Debug.Assert(_buffer != null && _bufferIndex != null); 279if (_bufferIndex.Value < _buffer.Count - 1) 281for (_bufferIndex.Value++; _bufferIndex.Value < _buffer.Count; _bufferIndex.Value++) 285if (_keyComparer.Compare(_buffer[_bufferIndex.Value].Second, minKey) > 0) 287currentElement = _buffer[_bufferIndex.Value].First; 288currentKey = _buffer[_bufferIndex.Value].Second;