InternalDequeueChunk()

T[] System.Linq.Parallel.AsynchronousChannel< T >.InternalDequeueChunk ( )

inlineprivate

Definition at line 227 of file AsynchronousChannel.cs.

    {
        int consumerBufferIndex = _consumerBufferIndex;
        T[] result = _buffer[consumerBufferIndex];
        _buffer[consumerBufferIndex] = null;
        Interlocked.Exchange(ref _consumerBufferIndex, (consumerBufferIndex + 1) % _buffer.Length);
        if (_producerIsWaiting == 1 && !IsFull)
        {
            _producerIsWaiting = 0;
            _producerEvent.Set();
        }
        return result;
    }

References System.Linq.Parallel.AsynchronousChannel< T >._buffer, System.Linq.Parallel.AsynchronousChannel< T >._consumerBufferIndex, System.Linq.Parallel.AsynchronousChannel< T >._producerEvent, System.Linq.Parallel.AsynchronousChannel< T >._producerIsWaiting, System.Threading.Interlocked.Exchange(), System.Linq.Parallel.AsynchronousChannel< T >.IsFull, and System.Threading.ManualResetEventSlim.Set().

Referenced by System.Linq.Parallel.AsynchronousChannel< T >.TryDequeueChunk(), and System.Linq.Parallel.AsynchronousChannel< T >.TryDequeueChunk().