using System;

using System.Threading;

using System.Threading.Tasks;

public class Program

{

    public static void Main()

    {

        BarrierDemo.BarrierSample();

    }

}

​

​

public class BarrierDemo

{

    public static void BarrierSample()

    {

        using (var barrier = new Barrier(2, (b) => Console.WriteLine("Barrier: phase={0}", b.CurrentPhaseNumber)))

        {

            Parallel.Invoke(

                () => {

                    Console.WriteLine("I'm thread one, and I start by runing the query");

                    // Let the other thread perform the query while the transaction is still pending

                    barrier.SignalAndWait();

                    // Wait until the other thread enf performing the dirty read

                    barrier.SignalAndWait();

                    Console.WriteLine("I'm thread one, and I rollback");

                }, 

                () => {                 

                    // Wait until the first thread run the query

                    barrier.SignalAndWait();

                    Console.WriteLine("I'm thread two, and I run my query");

                    // Let the first thread rollback/commit the transaction

                    barrier.SignalAndWait();

                }

            );

        }

    }

}