Execute()

void IMergeHelper< TInputOutput >. System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >.Execute ( )

inlineprivate

Implements System.Linq.Parallel.IMergeHelper< TInputOutput >.

Definition at line 52 of file DefaultMergeHelper.cs.

    {
        if (_asyncChannels != null)
        {
            SpoolingTask.SpoolPipeline(_taskGroupState, _partitions, _asyncChannels, _taskScheduler);
        }
        else if (_syncChannels != null)
        {
            SpoolingTask.SpoolStopAndGo(_taskGroupState, _partitions, _syncChannels, _taskScheduler);
        }
        else if (_ignoreOutput)
        {
            SpoolingTask.SpoolForAll(_taskGroupState, _partitions, _taskScheduler);
        }
    }

References System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._asyncChannels, System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._ignoreOutput, System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._partitions, System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._syncChannels, System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._taskGroupState, and System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._taskScheduler.