TryDequeueChunk() [2/2]

bool System.Linq.Parallel.AsynchronousChannel< T >.TryDequeueChunk ( [NotNullWhen(true)] ref T[] chunk, ref bool isDone )

inlineprivate

Definition at line 206 of file AsynchronousChannel.cs.

    {
        isDone = false;
        while (IsChunkBufferEmpty)
        {
            if (IsDone && IsChunkBufferEmpty)
            {
                isDone = true;
                return false;
            }
            Interlocked.Exchange(ref _consumerIsWaiting, 1);
            if (IsChunkBufferEmpty && !IsDone)
            {
                return false;
            }
            _consumerIsWaiting = 0;
        }
        chunk = InternalDequeueChunk();
        return true;
    }

References System.Linq.Parallel.AsynchronousChannel< T >._consumerIsWaiting, System.Threading.Interlocked.Exchange(), System.Linq.Parallel.AsynchronousChannel< T >.InternalDequeueChunk(), System.Linq.Parallel.AsynchronousChannel< T >.IsChunkBufferEmpty, and System.Linq.Parallel.AsynchronousChannel< T >.IsDone.