SpoolingFinally()

override void System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >.SpoolingFinally ( )

inlineprotectedvirtual

Reimplemented from System.Linq.Parallel.SpoolingTaskBase.

Definition at line 109 of file OrderPreservingPipeliningSpoolingTask.cs.

    {
        lock (_bufferLock)
        {
            _producerDone[_partitionIndex] = true;
            if (_consumerWaiting[_partitionIndex])
            {
                Monitor.Pulse(_bufferLock);
                _consumerWaiting[_partitionIndex] = false;
            }
        }
        base.SpoolingFinally();
        _partition.Dispose();
    }

References System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >._bufferLock, System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >._consumerWaiting, System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >._partition, System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >._partitionIndex, System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >._producerDone, System.Linq.Parallel.QueryOperatorEnumerator< TElement, TKey >.Dispose(), and System.Threading.Monitor.Pulse().