TryWaitForElement()

bool System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.TryWaitForElement ( int producer, ref Pair< TKey, TOutput > element )

inlineprivate

Definition at line 121 of file OrderPreservingPipeliningMergeHelper.cs.

        {
            Queue<Pair<TKey, TOutput>> queue = _mergeHelper._buffers[producer];
            object obj = _mergeHelper._bufferLocks[producer];
            lock (obj)
            {
                if (queue.Count == 0)
                {
                    if (_mergeHelper._producerDone[producer])
                    {
                        element = default(Pair<TKey, TOutput>);
                        return false;
                    }
                    _mergeHelper._consumerWaiting[producer] = true;
                    Monitor.Wait(obj);
                    if (queue.Count == 0)
                    {
                        element = default(Pair<TKey, TOutput>);
                        return false;
                    }
                }
                if (_mergeHelper._producerWaiting[producer])
                {
                    Monitor.Pulse(obj);
                    _mergeHelper._producerWaiting[producer] = false;
                }
                if (queue.Count < 1024)
                {
                    element = queue.Dequeue();
                    return true;
                }
                _privateBuffer[producer] = _mergeHelper._buffers[producer];
                _mergeHelper._buffers[producer] = new Queue<Pair<TKey, TOutput>>(128);
            }
            bool flag = TryGetPrivateElement(producer, ref element);
            return true;
        }

References System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._mergeHelper, System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._privateBuffer, System.Collections.Generic.Dictionary< TKey, TValue >.Count, System.obj, System.Threading.Monitor.Pulse(), System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.TryGetPrivateElement(), and System.Threading.Monitor.Wait().

Referenced by System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.MoveNext().