using System;

using System.Threading.Tasks;

using System.Linq;

using System.Collections;

using System.Collections.Generic;

using Polly;

using Polly.Bulkhead;

public class Program

{

    static async Task Main(string[] args)

    {

        var groupedObjects = Enumerable.Range(0, 10)

            .Select(n => new object[] { n }); // Create 10 sets to work with

        var bulkheadPolicy = Policy

            .BulkheadAsync(3, 3); // maxParallelization, maxQueuingActions

        var parallelTasks = new List<Task>();

        foreach (var set in groupedObjects)

        {

            Console.WriteLine(@$"Scheduling, Available: {bulkheadPolicy

                .BulkheadAvailableCount}, QueueAvailable: {bulkheadPolicy

                .QueueAvailableCount}");

​

            // Start the task

            var task = bulkheadPolicy.ExecuteAsync(async () =>

            {

                // Await the task without capturing the context

                await DoSomethingAsync(set).ConfigureAwait(false);

            });

            parallelTasks.Add(task);

            await Task.Delay(50); // Interval between scheduling more tasks

        }

        var whenAllTasks = Task.WhenAll(parallelTasks);

        try

        {

            // Await all the tasks (await throws only one of the exceptions)

            await whenAllTasks;

        }

        catch when (whenAllTasks.IsFaulted) // It might also be canceled

        {

            // Ignore rejections, rethrow other exceptions

            whenAllTasks.Exception.Handle(ex => ex is BulkheadRejectedException);

        }

        Console.WriteLine(@$"Processed: {parallelTasks

            .Where(t => t.Status == TaskStatus.RanToCompletion).Count()}");

        Console.WriteLine($"Faulted: {parallelTasks.Where(t => t.IsFaulted).Count()}");

    }

    static async Task DoSomethingAsync(IEnumerable<object> set)

    {

        // Pretend we are doing something with the set

        await Task.Delay(500).ConfigureAwait(false);

    }

}