TryDequeueIfSlow()

bool System.Threading.Tasks.SingleProducerSingleConsumerQueue< T >.TryDequeueIfSlow ( Predicate< T > predicate, ref Segment segment, ref T[] array, [MaybeNullWhen(false)] out T result )

inlineprivate

Definition at line 259 of file SingleProducerSingleConsumerQueue.cs.

    {
        if (segment._state._last != segment._state._lastCopy)
        {
            segment._state._lastCopy = segment._state._last;
            return TryDequeueIf(predicate, out result);
        }
        if (segment._next != null && segment._state._first == segment._state._last)
        {
            segment = segment._next;
            array = segment._array;
            _head = segment;
        }
        int first = segment._state._first;
        if (first == segment._state._last)
        {
            result = default(T);
            return false;
        }
        result = array[first];
        if (predicate == null || predicate(result))
        {
            array[first] = default(T);
            segment._state._first = (first + 1) & (segment._array.Length - 1);
            segment._state._lastCopy = segment._state._last;
            return true;
        }
        result = default(T);
        return false;
    }

References System.Threading.Tasks.SingleProducerSingleConsumerQueue< T >._head, System.array, and System.Threading.Tasks.SingleProducerSingleConsumerQueue< T >.TryDequeueIf().

Referenced by System.Threading.Tasks.SingleProducerSingleConsumerQueue< T >.TryDequeueIf().