using System;

using System.Threading;

using System.Threading.Tasks;

using Nito.AsyncEx;

​

namespace ReadWriteQueue

{

    public static class Locks

    {

        public static readonly AsyncLock ReadLock = new();

        public static readonly AsyncLock WriteLock = new();

    }

​

    // их может быть N

    public class ThreadLikeSomethingProcessor

    {

        private static AwaitableDisposable<IDisposable>? _writeLockTask;

​

        public static void Main()

        {

            // некий старт

            _writeLockTask = Locks.WriteLock.LockAsync();

​

            // предположительный цикл чтений

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

            {

                var thread = new Thread(DoWork);

                thread.Start(i);

            }

            Thread.Sleep(1000);

        }

​

        private static void ReadData(object num)

        {

            Console.WriteLine($"read {num}");

        }

​

        private static void WriteData(object num)

        {

            Console.WriteLine($"write {num}");

        }

​

        public static void DoWork(object num)

        {

            ReadData(num);

​

            if (_writeLockTask == null)

                return;

​

            _ = Task.Run(async () =>

            {

                var wLock = await _writeLockTask.Value;

                WriteData(num);

                wLock.Dispose();

            });

        }

    }

}