◆ SpoolingWork()

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

inlineprotected

Definition at line 41 of file OrderPreservingPipeliningSpoolingTask.cs.

    {
        TOutput currentElement = default(TOutput);
        TKey currentKey = default(TKey);
        int num = ((!_autoBuffered) ? 1 : 16);
        Pair<TKey, TOutput>[] array = new Pair<TKey, TOutput>[num];
        QueryOperatorEnumerator<TOutput, TKey> partition = _partition;
        CancellationToken mergedCancellationToken = _taskGroupState.CancellationState.MergedCancellationToken;
        int i;
        do
        {
            for (i = 0; i < num; i++)
            {
                if (!partition.MoveNext(ref currentElement, ref currentKey))
                {
                    break;
                }
                array[i] = new Pair<TKey, TOutput>(currentKey, currentElement);
            }
            if (i == 0)
            {
                break;
            }
            lock (_bufferLock)
            {
                if (mergedCancellationToken.IsCancellationRequested)
                {
                    break;
                }
                for (int j = 0; j < i; j++)
                {
                    _buffers[_partitionIndex].Enqueue(array[j]);
                }
                if (_consumerWaiting[_partitionIndex])
                {
                    Monitor.Pulse(_bufferLock);
                    _consumerWaiting[_partitionIndex] = false;
                }
                if (_buffers[_partitionIndex].Count >= 8192)
                {
                    _producerWaiting[_partitionIndex] = true;
                    Monitor.Wait(_bufferLock);
                }
            }
        }
        while (i == num);
    }