TrySteal()

bool System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue.TrySteal ( [MaybeNullWhen(false)] out T result, bool take )

inlinepackage

Definition at line 206 of file ConcurrentBag.cs.

        {
            lock (this)
            {
                int headIndex = _headIndex;
                if (take)
                {
                    if (headIndex - (_tailIndex - 2) >= 0 && _currentOp == 1)
                    {
                        SpinWait spinWait = default(SpinWait);
                        do
                        {
                            spinWait.SpinOnce();
                        }
                        while (_currentOp == 1);
                    }
                    Interlocked.Exchange(ref _headIndex, headIndex + 1);
                    if (headIndex < _tailIndex)
                    {
                        int num = headIndex & _mask;
                        result = _array[num];
                        if (RuntimeHelpers.IsReferenceOrContainsReferences<T>())
                        {
                            _array[num] = default(T);
                        }
                        _stealCount++;
                        return true;
                    }
                    _headIndex = headIndex;
                }
                else if (headIndex < _tailIndex)
                {
                    result = _array[headIndex & _mask];
                    return true;
                }
            }
            result = default(T);
            return false;
        }

References System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue._array, System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue._currentOp, System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue._headIndex, System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue._mask, System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue._stealCount, System.Collections.Concurrent.ConcurrentBag< T >.WorkStealingQueue._tailIndex, and System.Threading.Interlocked.Exchange().