using System;

using System.Collections.Concurrent;

using System.Threading;

using System.Threading.Tasks;

using System.Collections.Generic;

​

public class Program

{

    private static BlockingCollection<Task<int>> BlockingCollection {get;set;}  

    public static void RealizarPizza(int numTasks)

    {

        Random r = new Random();

        while (true) {

            for(int i = 0 ; i < numTasks ; i++)

            {

                int closured = i;

                Task<int> task = new Task<int>(()=>

                { 

                    Thread.Sleep(r.Next(1,3));

                    Console.WriteLine("Pizza: " + closured);

                    return closured;

                });

                BlockingCollection.Add(task);

                task.Start();

            }

        BlockingCollection.CompleteAdding();

        }

    }

    public static void Main()

    {

        int numTasks = 100;

        int maxParallelism = 5;

​

        BlockingCollection = new BlockingCollection<Task<int>>(maxParallelism);

        Task.Factory.StartNew(()=> RealizarPizza(numTasks));

        foreach(var task in BlockingCollection.GetConsumingEnumerable())

        {

            task.Wait();

            Console.WriteLine("                 ¡¡¡¡Pizza Entregada!!!!: "+ task.Result);

            task.Dispose();

        }

    }

}