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

{

    public static void Main()

    {

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

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

        {

            var thread = new Thread(DoWork);

            thread.Start(i);

        }

    }

​

    private static AwaitableDisposable<IDisposable> ReadData(object num)

    {

        AwaitableDisposable<IDisposable> writeLockTask;

        // блокируем только на время взятия таски лока на запись

        var rLock = Locks.ReadLock.Lock();

        try

        {

            writeLockTask = Locks.WriteLock.LockAsync();

            // запускаем таску, чтобы оно положилось в очередь, но не ждем

            writeLockTask.AsTask();

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

        }

        finally

        {

            rLock.Dispose();

        }

        // делаем чтение без блокировки

        // ...

        return writeLockTask;

    }

​

    private static void WriteData(object num)

    {

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

    }

​

    public static void DoWork(object num)

    {

        var writeLockTask = ReadData(num);

        var lck = writeLockTask.GetAwaiter().GetResult();

        WriteData(num);

        lck.Dispose();

    }

}

}