Dispose()

override void System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator.Dispose ( )

inlinevirtual

Reimplemented from System.Linq.Parallel.MergeEnumerator< TOutput >.

Definition at line 174 of file OrderPreservingPipeliningMergeHelper.cs.

        {
            int num = _mergeHelper._buffers.Length;
            for (int i = 0; i < num; i++)
            {
                object obj = _mergeHelper._bufferLocks[i];
                lock (obj)
                {
                    if (_mergeHelper._producerWaiting[i])
                    {
                        Monitor.Pulse(obj);
                    }
                }
            }
            base.Dispose();
        }

References System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderedPipeliningMergeEnumerator._mergeHelper, System.obj, and System.Threading.Monitor.Pulse().