using System;

using System.Linq;

using System.Threading;

using System.Threading.Tasks;

public class Program

{

    public static void Main()

    {

        new Program().Execute();

    }

    // Initial method that will fire the threads

    public void Execute()

    {

        // This object will be responsible to lock the objects

        this.fixErrorLock = new object();

        var objectsToIterate = new int[] {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14 };

        // For each element in the collection the given action will be executed passing the current item as parameter.

        //Parallel.ForEach(objectsToIterate, this.DoWork);

        objectsToIterate.AsParallel().ForAll(this.DoWork);

    }

    private object fixErrorLock;

    public void DoWork(int myParam)

    {

        try

        {

            if(myParam % 4 == 0)

            {

                throw new Exception();  

            }

            // Thread executed without error

        }catch(Exception ex)

        {

            this.PrintThreadMessage("Waiting to check if the problem have to be solved.");

            lock(fixErrorLock)

            {

                this.FixTheProblem(ref myParam);

                this.PrintThreadMessage("Problem solved!");

            }

            this.DoWork(myParam);

        }

    }

    public void FixTheProblem(ref int param)

    {       

        this.PrintThreadMessage("Solving the problem...");

        Thread.Sleep(100);

        param--;

    }

    private void PrintThreadMessage(string message)

    {

        Console.WriteLine(string.Format("{0} (Thread id: {1})", message , Thread.CurrentThread.ManagedThreadId));

    }

}