ForEachWorker< TSource, TLocal >() [1/3]

static ParallelLoopResult System.Threading.Tasks.Parallel.ForEachWorker< TSource, TLocal > ( IEnumerable< TSource > source, ParallelOptions parallelOptions, Action< TSource > body, Action< TSource, ParallelLoopState > bodyWithState, Action< TSource, ParallelLoopState, long > bodyWithStateAndIndex, Func< TSource, ParallelLoopState, TLocal, TLocal > bodyWithStateAndLocal, Func< TSource, ParallelLoopState, long, TLocal, TLocal > bodyWithEverything, Func< TLocal > localInit, Action< TLocal > localFinally )

inlinestaticprivate

Definition at line 932 of file Parallel.cs.

    {
        parallelOptions.CancellationToken.ThrowIfCancellationRequested();
        if (source is TSource[] array)
        {
            return ForEachWorker(array, parallelOptions, body, bodyWithState, bodyWithStateAndIndex, bodyWithStateAndLocal, bodyWithEverything, localInit, localFinally);
        }
        if (source is IList<TSource> list)
        {
            return ForEachWorker(list, parallelOptions, body, bodyWithState, bodyWithStateAndIndex, bodyWithStateAndLocal, bodyWithEverything, localInit, localFinally);
        }
        return PartitionerForEachWorker(Partitioner.Create(source), parallelOptions, body, bodyWithState, bodyWithStateAndIndex, bodyWithStateAndLocal, bodyWithEverything, localInit, localFinally);
    }

References System.array, System.Collections.Concurrent.Partitioner< TSource >.Create(), System.list, and System.source.