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 Flettu.Lock.AsyncLock();

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

            {

                var raceCondition = 0;

                // You can acquire the lock asynchronously

                using (await asyncLock.AcquireAsync(CancellationToken.None))

                {

                    await Task.WhenAll(

                        Task.Run(async () =>

                        {

                            // The lock is reentrant

                            using (await asyncLock.AcquireAsync(CancellationToken.None))

                            {

                                // The lock provides mutual exclusion

                                raceCondition++;

                            }

                        }),

                        Task.Run(async () =>

                        {

                            using (await asyncLock.AcquireAsync(CancellationToken.None))

                            {

                                raceCondition++;

                            }

                        })

                    );

                }

                if (raceCondition != 2)

                {

                    Console.WriteLine("Not okay");

                    return;

                }

            }

            Console.WriteLine("Ok");

        }).Wait();

    }

}