System.Collections.Async.ParallelForEachExtensions

public static class ParallelForEachExtensions

Extensions methods for IEnumerable and IAsyncEnumerable to do parallel for-each loop in async-await manner

public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel

public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)

Invokes an asynchronous action on each item in the collection in parallel