1 write to _partitionCount
System.Linq.Parallel (1)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)
79
_partitionCount
= partitionCount;
8 references to _partitionCount
System.Linq.Parallel (8)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (8)
109
if (
_partitionCount
== 1)
142
while (mutables._currentBufferIndex <
_partitionCount
)
184
if (mutables._currentBufferIndex <
_partitionCount
)
204
ListChunk<Pair<TInputOutput, THashKey>>[] privateBuffers = new ListChunk<Pair<TInputOutput, THashKey>>[
_partitionCount
];
221
destinationIndex = _repartitionStream.GetHashCode(elementHashKey) %
_partitionCount
;
226
destinationIndex = _repartitionStream.GetHashCode(element) %
_partitionCount
;
229
Debug.Assert(0 <= destinationIndex && destinationIndex <
_partitionCount
,
251
for (int i = 0; i <
_partitionCount
; i++)