SpoolForAll< TInputOutput, TIgnoreKey >()

static void System.Linq.Parallel.SpoolingTask.SpoolForAll< TInputOutput, TIgnoreKey > ( QueryTaskGroupState groupState, PartitionedStream< TInputOutput, TIgnoreKey > partitions, TaskScheduler taskScheduler )

inlinestaticpackage

Definition at line 39 of file SpoolingTask.cs.

    {
        Task task = new Task(delegate
        {
            int num = partitions.PartitionCount - 1;
            for (int i = 0; i < num; i++)
            {
                QueryTask queryTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i]);
                queryTask.RunAsynchronously(taskScheduler);
            }
            QueryTask queryTask2 = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(num, groupState, partitions[num]);
            queryTask2.RunSynchronously(taskScheduler);
        });
        groupState.QueryBegin(task);
        task.RunSynchronously(taskScheduler);
        groupState.QueryEnd(userInitiatedDispose: false);
    }

References System.Linq.Parallel.QueryTaskGroupState.QueryBegin(), System.Linq.Parallel.QueryTaskGroupState.QueryEnd(), System.Linq.Parallel.QueryTask.RunAsynchronously(), System.Linq.Parallel.QueryTask.RunSynchronously(), and System.task.