using System;

using System.Threading;

using System.Threading.Tasks;

using Nito.AsyncEx;

​

namespace ReadWriteQueue

{

    public static class Locks

{

    public static readonly SemaphoreSlim ReadLock = new(1,1);

    public static readonly SemaphoreSlim WriteLock = new(1,1);

}

​

// их может быть 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 Task ReadData(object num)

    {

        Task writeLockTask = null;

        var rLock = Locks.ReadLock;

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

        rLock.Wait();

        try

        {

            writeLockTask = Locks.WriteLock.WaitAsync(); 

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

        }

        finally

        {

            rLock.Release();

        }

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

        Thread.Sleep(1000*(int)num);

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

        return writeLockTask;

    }

​

    private static void WriteData(object num)

    {

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

    }

​

    public static void DoWork(object num)

    {

        var writeLockTask = ReadData(num);

        writeLockTask.Wait();

        WriteData(num);

        Locks.WriteLock.Release();

    }

}

}