DefaultMergeHelper()

System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >.DefaultMergeHelper ( PartitionedStream< TInputOutput, TIgnoreKey > partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, CancellationState cancellationState, int queryId )

inlinepackage

Definition at line 22 of file DefaultMergeHelper.cs.

    {
        _taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
        _partitions = partitions;
        _taskScheduler = taskScheduler;
        _ignoreOutput = ignoreOutput;
        IntValueEvent consumerEvent = new IntValueEvent();
        if (ignoreOutput)
        {
            return;
        }
        if (options != ParallelMergeOptions.FullyBuffered)
        {
            if (partitions.PartitionCount > 1)
            {
                _asyncChannels = MergeExecutor<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerEvent, cancellationState.MergedCancellationToken);
                _channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(_taskGroupState, _asyncChannels, consumerEvent);
            }
            else
            {
                _channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], _taskGroupState.CancellationState).GetEnumerator();
            }
        }
        else
        {
            _syncChannels = MergeExecutor<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount);
            _channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(_taskGroupState, _syncChannels);
        }
    }

References System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._asyncChannels, System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._channelEnumerator, 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, System.Linq.Parallel.DefaultMergeHelper< TInputOutput, TIgnoreKey >._taskScheduler, System.Linq.Parallel.QueryTaskGroupState.CancellationState, and System.options.