◆ OrderPreservingPipeliningMergeHelper()

System.Linq.Parallel.OrderPreservingPipeliningMergeHelper< TOutput, TKey >.OrderPreservingPipeliningMergeHelper	(	PartitionedStream< TOutput, TKey >	partitions,
		TaskScheduler	taskScheduler,
		CancellationState	cancellationState,
		bool	autoBuffered,
		int	queryId,
		IComparer< TKey >	keyComparer )

inlinepackage

Definition at line 212 of file OrderPreservingPipeliningMergeHelper.cs.

    {
        _taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
        _partitions = partitions;
        _taskScheduler = taskScheduler;
        _autoBuffered = autoBuffered;
        int partitionCount = _partitions.PartitionCount;
        _buffers = new Queue<Pair<TKey, TOutput>>[partitionCount];
        _producerDone = new bool[partitionCount];
        _consumerWaiting = new bool[partitionCount];
        _producerWaiting = new bool[partitionCount];
        _bufferLocks = new object[partitionCount];
        if (keyComparer == Util.GetDefaultComparer<int>())
        {
            _producerComparer = (IComparer<Producer<TKey>>)(object)ProducerComparerInt.Instance;
        }
        else
        {
            _producerComparer = new ProducerComparer(keyComparer);
        }
    }