SpoolPipeline< TInputOutput, TIgnoreKey >()

static void System.Linq.Parallel.SpoolingTask.SpoolPipeline< TInputOutput, TIgnoreKey > ( QueryTaskGroupState groupState, PartitionedStream< TInputOutput, TIgnoreKey > partitions, AsynchronousChannel< TInputOutput >[] channels, TaskScheduler taskScheduler )

inlinestaticpackage

Definition at line 25 of file SpoolingTask.cs.

    {
        Task task = new Task(delegate
        {
            for (int i = 0; i < partitions.PartitionCount; i++)
            {
                QueryTask queryTask = new PipelineSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]);
                queryTask.RunAsynchronously(taskScheduler);
            }
        });
        groupState.QueryBegin(task);
        task.Start(taskScheduler);
    }

References System.Linq.Parallel.PartitionedStream< TElement, TKey >.PartitionCount, System.Linq.Parallel.QueryTaskGroupState.QueryBegin(), System.Linq.Parallel.QueryTask.RunAsynchronously(), and System.task.