4 writes to _consumerChunk
System.Linq.Parallel (4)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (4)
408if (!TryDequeueChunk(ref _consumerChunk)) 427_consumerChunk = null; 486if (!TryDequeueChunk(ref _consumerChunk, ref isDone)) 504_consumerChunk = null;
12 references to _consumerChunk
System.Linq.Parallel (12)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (12)
406if (_consumerChunk == null) 410Debug.Assert(_consumerChunk == null); 418Debug.Assert(_consumerChunk != null, "consumer chunk is null"); 419Debug.Assert(0 <= _consumerChunkIndex && _consumerChunkIndex < _consumerChunk.Length, "chunk index out of bounds"); 420item = _consumerChunk[_consumerChunkIndex]; 425if (_consumerChunkIndex == _consumerChunk.Length) 484if (_consumerChunk == null) 488Debug.Assert(_consumerChunk == null); 496Debug.Assert(_consumerChunk != null, "consumer chunk is null"); 497Debug.Assert(0 <= _consumerChunkIndex && _consumerChunkIndex < _consumerChunk.Length, "chunk index out of bounds"); 498item = _consumerChunk[_consumerChunkIndex]; 502if (_consumerChunkIndex == _consumerChunk.Length)