◆ MoveNext() [2/2]

override bool System.Linq.Parallel.HashRepartitionEnumerator< TInputOutput, THashKey, TIgnoreKey >.MoveNext	(	ref Pair< TInputOutput, THashKey >	currentElement,
		ref int	currentKey )

inlinepackage

Definition at line 51 of file HashRepartitionEnumerator.cs.

    {
        if (_partitionCount == 1)
        {
            TIgnoreKey currentKey2 = default(TIgnoreKey);
            TInputOutput currentElement2 = default(TInputOutput);
            if (_source.MoveNext(ref currentElement2, ref currentKey2))
            {
                currentElement = new Pair<TInputOutput, THashKey>(currentElement2, (_keySelector == null) ? default(THashKey) : _keySelector(currentElement2));
                return true;
            }
            return false;
        }
        Mutables mutables = _mutables;
        if (mutables == null)
        {
            mutables = (_mutables = new Mutables());
        }
        if (mutables._currentBufferIndex == -1)
        {
            EnumerateAndRedistributeElements();
        }
        while (mutables._currentBufferIndex < _partitionCount)
        {
            if (mutables._currentBuffer != null)
            {
                if (++mutables._currentIndex < mutables._currentBuffer.Count)
                {
                    currentElement = mutables._currentBuffer._chunk[mutables._currentIndex];
                    return true;
                }
                mutables._currentIndex = -1;
                mutables._currentBuffer = mutables._currentBuffer.Next;
                continue;
            }
            if (mutables._currentBufferIndex == _partitionIndex)
            {
                _barrier.Wait(_cancellationToken);
                mutables._currentBufferIndex = -1;
            }
            mutables._currentBufferIndex++;
            mutables._currentIndex = -1;
            if (mutables._currentBufferIndex == _partitionIndex)
            {
                mutables._currentBufferIndex++;
            }
            if (mutables._currentBufferIndex < _partitionCount)
            {
                mutables._currentBuffer = _valueExchangeMatrix[mutables._currentBufferIndex][_partitionIndex];
            }
        }
        return false;
    }