_buffer

1 write to _buffer

System.Linq.Parallel (1)

System\Linq\Parallel\Channels\AsynchronousChannel.cs (1)

125_buffer = new T[capacity + 1][];

6 references to _buffer

System.Linq.Parallel (6)

System\Linq\Parallel\Channels\AsynchronousChannel.cs (6)

161(consumerIndex == 0 && producerIndex == _buffer.Length - 1); 299_buffer[bufferIndex] = chunk; 305Interlocked.Exchange(ref _producerBufferIndex, (bufferIndex + 1) % _buffer.Length); 611T[] chunk = _buffer[consumerBufferIndex]!; 615_buffer[consumerBufferIndex] = null; 621Interlocked.Exchange(ref _consumerBufferIndex, (consumerBufferIndex + 1) % _buffer.Length);