2 writes to _producerChunkIndex
System.Linq.Parallel (2)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (2)
133_producerChunkIndex = 0; 271_producerChunkIndex = (producerChunkIndex + 1) % _chunkSize;
6 references to _producerChunkIndex
System.Linq.Parallel (6)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (6)
261int producerChunkIndex = _producerChunkIndex; 380if (_producerChunk != null && _producerChunkIndex != 0) 383Debug.Assert(1 <= _producerChunkIndex && _producerChunkIndex <= _chunkSize); 384T[] leftOverChunk = new T[_producerChunkIndex]; 385Array.Copy(_producerChunk, leftOverChunk, _producerChunkIndex);