InitializePartitions()

void System.Linq.Parallel.PartitionedDataSource< T >.InitializePartitions ( IEnumerable< T > source, int partitionCount, bool useStriping )

inlineprivate

Definition at line 402 of file PartitionedDataSource.cs.

    {
        if (source is ParallelEnumerableWrapper<T> parallelEnumerableWrapper)
        {
            source = parallelEnumerableWrapper.WrappedEnumerable;
        }
        if (source is IList<T> data)
        {
            QueryOperatorEnumerator<T, int>[] array = new QueryOperatorEnumerator<T, int>[partitionCount];
            T[] array2 = source as T[];
            int num = -1;
            if (useStriping)
            {
                num = Scheduling.GetDefaultChunkSize<T>();
                if (num < 1)
                {
                    num = 1;
                }
            }
            for (int i = 0; i < partitionCount; i++)
            {
                if (array2 != null)
                {
                    if (useStriping)
                    {
                        array[i] = new ArrayIndexRangeEnumerator(array2, partitionCount, i, num);
                    }
                    else
                    {
                        array[i] = new ArrayContiguousIndexRangeEnumerator(array2, partitionCount, i);
                    }
                }
                else if (useStriping)
                {
                    array[i] = new ListIndexRangeEnumerator(data, partitionCount, i, num);
                }
                else
                {
                    array[i] = new ListContiguousIndexRangeEnumerator(data, partitionCount, i);
                }
            }
            _partitions = array;
        }
        else
        {
            _partitions = MakePartitions(source.GetEnumerator(), partitionCount);
        }
    }

References System.Linq.Parallel.PartitionedStream< T, int >._partitions, System.array, System.Linq.Parallel.PartitionedDataSource< T >.MakePartitions(), and System.Linq.source.

Referenced by System.Linq.Parallel.PartitionedDataSource< T >.PartitionedDataSource().