ctigeek

public static class ParallelTaskRunnerExtension
    {
        public static void RunTasks(this IEnumerable<Task> tasks, int maxConcurrency, Action<Task> taskComplete = null)
        {
            if (maxConcurrency <= 0) throw new ArgumentException("maxConcurrency must be more than 0.");
            int taskCount = 0;
            int nextIndex = 0;
            var currentTasks = new Task[maxConcurrency];

            foreach (var task in tasks)