GenerateSortHelpers()

static SortHelper< TInputOutput, TKey >[] System.Linq.Parallel.SortHelper< TInputOutput, TKey >.GenerateSortHelpers ( PartitionedStream< TInputOutput, TKey > partitions, QueryTaskGroupState groupState )

inlinestaticpackage

Definition at line 46 of file SortHelper.cs.

    {
        int partitionCount = partitions.PartitionCount;
        SortHelper<TInputOutput, TKey>[] array = new SortHelper<TInputOutput, TKey>[partitionCount];
        int num = 1;
        int num2 = 0;
        while (num < partitionCount)
        {
            num2++;
            num <<= 1;
        }
        int[][] sharedIndices = new int[partitionCount][];
        GrowingArray<TKey>[] sharedkeys = new GrowingArray<TKey>[partitionCount];
        TInputOutput[][] sharedValues = new TInputOutput[partitionCount][];
        Barrier[][] array2 = JaggedArray<Barrier>.Allocate(num2, partitionCount);
        if (partitionCount > 1)
        {
            int num3 = 1;
            for (int i = 0; i < array2.Length; i++)
            {
                for (int j = 0; j < array2[i].Length; j++)
                {
                    if (j % num3 == 0)
                    {
                        array2[i][j] = new Barrier(2);
                    }
                }
                num3 *= 2;
            }
        }
        for (int k = 0; k < partitionCount; k++)
        {
            array[k] = new SortHelper<TInputOutput, TKey>(partitions[k], partitionCount, k, groupState, sharedIndices, partitions.OrdinalIndexState, partitions.KeyComparer, sharedkeys, sharedValues, array2);
        }
        return array;
    }

References System.array.

Referenced by System.Linq.Parallel.OrderPreservingSpoolingTask< TInputOutput, TKey >.Spool().