MakePartitions()

static QueryOperatorEnumerator< T, int >[] System.Linq.Parallel.PartitionedDataSource< T >.MakePartitions ( IEnumerator< T > source, int partitionCount )

inlinestaticprivate

Definition at line 451 of file PartitionedDataSource.cs.

    {
        QueryOperatorEnumerator<T, int>[] array = new QueryOperatorEnumerator<T, int>[partitionCount];
        object sourceSyncLock = new object();
        Shared<int> currentIndex = new Shared<int>(0);
        Shared<int> degreeOfParallelism = new Shared<int>(partitionCount);
        Shared<bool> exceptionTracker = new Shared<bool>(value: false);
        for (int i = 0; i < partitionCount; i++)
        {
            array[i] = new ContiguousChunkLazyEnumerator(source, exceptionTracker, sourceSyncLock, currentIndex, degreeOfParallelism);
        }
        return array;
    }

References System.array, System.Linq.source, and System.value.

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