Spool()

static void System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey >.Spool ( QueryTaskGroupState groupState, PartitionedStream< TOutput, TKey > partitions, bool[] consumerWaiting, bool[] producerWaiting, bool[] producerDone, Queue< Pair< TKey, TOutput > >[] buffers, object[] bufferLocks, TaskScheduler taskScheduler, bool autoBuffered )

inlinestatic

Definition at line 89 of file OrderPreservingPipeliningSpoolingTask.cs.

    {
        int degreeOfParallelism = partitions.PartitionCount;
        for (int i = 0; i < degreeOfParallelism; i++)
        {
            buffers[i] = new Queue<Pair<TKey, TOutput>>(128);
            bufferLocks[i] = new object();
        }
        Task task = new Task(delegate
        {
            for (int j = 0; j < degreeOfParallelism; j++)
            {
                QueryTask queryTask = new OrderPreservingPipeliningSpoolingTask<TOutput, TKey>(partitions[j], groupState, consumerWaiting, producerWaiting, producerDone, j, buffers, bufferLocks[j], autoBuffered);
                queryTask.RunAsynchronously(taskScheduler);
            }
        });
        groupState.QueryBegin(task);
        task.Start(taskScheduler);
    }

References System.buffers, and System.task.