EnumerateAndRedistributeElements()

void System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >.EnumerateAndRedistributeElements ( )

inlineprivate

Definition at line 105 of file HashRepartitionEnumerator.cs.

    {
        Mutables mutables = _mutables;
        ListChunk<Pair<TInputOutput, THashKey>>[] array = new ListChunk<Pair<TInputOutput, THashKey>>[_partitionCount];
        TInputOutput currentElement = default(TInputOutput);
        TIgnoreKey currentKey = default(TIgnoreKey);
        int num = 0;
        while (_source.MoveNext(ref currentElement, ref currentKey))
        {
            if ((num++ & 0x3F) == 0)
            {
                _cancellationToken.ThrowIfCancellationRequested();
            }
            THashKey val = default(THashKey);
            int num2;
            if (_keySelector != null)
            {
                val = _keySelector(currentElement);
                num2 = _repartitionStream.GetHashCode(val) % _partitionCount;
            }
            else
            {
                num2 = _repartitionStream.GetHashCode(currentElement) % _partitionCount;
            }
            ListChunk<Pair<TInputOutput, THashKey>> listChunk = array[num2];
            if (listChunk == null)
            {
                listChunk = (array[num2] = new ListChunk<Pair<TInputOutput, THashKey>>(128));
            }
            listChunk.Add(new Pair<TInputOutput, THashKey>(currentElement, val));
        }
        for (int i = 0; i < _partitionCount; i++)
        {
            _valueExchangeMatrix[_partitionIndex][i] = array[i];
        }
        _barrier.Signal();
        mutables._currentBufferIndex = _partitionIndex;
        mutables._currentBuffer = array[_partitionIndex];
        mutables._currentIndex = -1;
    }

References System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._barrier, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._cancellationToken, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._keySelector, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._mutables, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._partitionCount, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._partitionIndex, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._repartitionStream, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._source, System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >._valueExchangeMatrix, System.Linq.Parallel.ListChunk< TInputOutput >.Add(), System.array, System.Linq.Parallel.HashRepartitionStream< TInputOutput, THashKey, TOrderKey >.GetHashCode(), System.Linq.Parallel.QueryOperatorEnumerator< TElement, TKey >.MoveNext(), System.Threading.CountdownEvent.Signal(), and System.Threading.CancellationToken.ThrowIfCancellationRequested().

Referenced by System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >.MoveNext().