ForEachAsync< TSource >() [7/8]

static Task System.Threading.Tasks.Parallel.ForEachAsync< TSource > ( IEnumerable< TSource > source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func< TSource, CancellationToken, ValueTask > body )

inlinestaticprivate

Definition at line 1496 of file Parallel.cs.

    {
        if (cancellationToken.IsCancellationRequested)
        {
            return Task.FromCanceled(cancellationToken);
        }
        if (dop < 0)
        {
            dop = DefaultDegreeOfParallelism;
        }
        Func<object, Task> taskBody = async delegate(object o)
        {
            SyncForEachAsyncState<TSource> state = (SyncForEachAsyncState<TSource>)o;
            bool launchedNext = false;
            try
            {
                while (!state.Cancellation.IsCancellationRequested)
                {
                    TSource current;
                    lock (state)
                    {
                        if (!state.Enumerator.MoveNext())
                        {
                            break;
                        }
                        current = state.Enumerator.Current;
                    }
                    if (!launchedNext)
                    {
                        launchedNext = true;
                        state.QueueWorkerIfDopAvailable();
                    }
                    await state.LoopBody(current, state.Cancellation.Token);
                }
            }
            catch (Exception e)
            {
                state.RecordException(e);
            }
            finally
            {
                if (state.SignalWorkerCompletedIterating())
                {
                    try
                    {
                        state.Dispose();
                    }
                    catch (Exception e2)
                    {
                        state.RecordException(e2);
                    }
                    state.Complete();
                }
            }
        };
        try
        {
            SyncForEachAsyncState<TSource> syncForEachAsyncState = new SyncForEachAsyncState<TSource>(source, taskBody, dop, scheduler, cancellationToken, body);
            syncForEachAsyncState.QueueWorkerIfDopAvailable();
            return syncForEachAsyncState.Task;
        }
        catch (Exception exception)
        {
            return Task.FromException(exception);
        }
    }

References System.cancellationToken, System.Threading.Tasks.Parallel.DefaultDegreeOfParallelism, System.exception, System.Threading.Tasks.Task< TResult >.FromCanceled(), System.Threading.Tasks.Task< TResult >.FromException(), System.scheduler, System.source, and System.state.