AsyncBlocker.NET 1.0.1.4

AsyncBlocker.NET

Run a method in a thread safe way, combining the behavior of a lock with the behavior of a semaphore.

using System.Threading.Tasks

Basic Usage

Take Control

Take control to run a method

You must call ReleaseWhenTaken or Stop before you can call Start again

_asyncBlocker.TakeWhenFree(); /* or */ _asyncBlocker.Start();

Release Control

Release Control which will allow another thread to call TakeWhenFree or Start

_asyncBlocker.ReleaseWhenTaken(); /* or */ _asyncBlocker.Stop();

Check Status

_asyncBlocker.Started

Lock

_asyncBlocker.Lock

Full Example

    internal class Program
    {
        static void Main()
        {
            AsyncBlocker asyncBlocker = new AsyncBlocker();

            Task.Run(async () =>
            {
                while (true)
                {
                    bool b = asyncBlocker.TakeWhenFree();

                    if (b)
                    {
                        Console.WriteLine("T1");

                        await Task.Delay(1000);

                        asyncBlocker.ReleaseWhenTaken();
                    }
                    else
                    {
                        Console.WriteLine("Blocked by T2");
                    }

                    await Task.Delay(500);
                }
            });

            Task.Run(async () =>
            {
                while (true)
                {
                    bool b = asyncBlocker.Start();

                    if (b)
                    {
                        Console.WriteLine("T2");

                        await Task.Delay(1000);

                        asyncBlocker.Stop();
                    }
                    else
                    {
                        Console.WriteLine("Blocked by T1");
                    }

                    await Task.Delay(500);
                }

            });

            Console.ReadLine();
        }
    }