using System;

using System.Threading.Tasks;

using System.Threading;

public class Program

{

    public static void Main()

    {

        Task.Run(async () =>

        {

            await Task.Delay(TimeSpan.FromSeconds(2));

            Console.WriteLine("Deadlocked?");

        });

        Task.Run(async () =>

        {

            var asyncLock = new Cogs.Threading.ReentrantAsyncLock();

            for (var i = 0; i < 1000; ++i)

            {

                var raceCondition = 0;

                // You can acquire the lock asynchronously

                await asyncLock.WithLockAsync(async () =>

                {

                    await Task.WhenAll(

                        Task.Run(async () =>

                        {

                            // The lock is reentrant

                            await asyncLock.WithLockAsync(async () =>

                            {

                                // The lock provides mutual exclusion

                                raceCondition++;

                            });

                        }),

                        Task.Run(async () =>

                        {

                            await asyncLock.WithLockAsync(async () =>

                            {

                                raceCondition++;

                            });

                        })

                    );

                });

                if (raceCondition != 2)

                {

                    Console.WriteLine("Not okay");

                    return;

                }

            }

            Console.WriteLine("Ok");

        }).Wait();

    }

}