Простая коллекция производителя-потребителя без BlockingCollection

Я думаю, что использование как lock, так и ManualResetEvent излишне. Я предлагаю вам узнать больше о ManualResetEvent о том, как входить и выходить из синхронизированных областей в вашем коде (вы также можете взглянуть на другие механизмы синхронизации, доступные в System.Threading).

Если это не только для упражнений, вы также можете взглянуть на NetMQ.

Надеюсь, поможет!

Согласно моему комментарию в вопросе,

Вот предлагаемое мной решение.

public class BlockingQueue<T>
{
    // In order to get rid of Lock object
    // Any thread should be able to add items to the queue
    private readonly ConcurrentQueue<T> _queue = new ConcurrentQueue<T>();

    // Only one thread is able to consume from queue
    // You can fine tune this to your interest
    private readonly SemaphoreSlim _slim = new SemaphoreSlim(1,1);

    public void Add(T item) {
        _queue.Enqueue(item);
    }

    public bool TryTake(out T item, TimeSpan timeout) {
        if (_slim.Wait(timeout)){
            return _queue.TryDequeue(out item);
        }
        item = default(T);
        return false;
    }
}

Microsoft недавно отказалась от System.Threading.Channels, который предназначен для предоставления оптимизированных API-интерфейсов производителя / потребителя, которые в данном случае могут хорошо подойти. Он охватывает неограниченные и ограниченные сценарии и включает в себя один и несколько сценариев чтения / записи. API довольно прост и интуитивно понятен в использовании; Единственное небольшое предостережение - это то, что он использует API-интерфейс, ориентированный на async (для потребителя и - в случае ограниченных каналов - для производителя).

Дело в том, что код, который вы не пишете, как правило, имеет меньше проблем, особенно если он был написан командой, обладающей опытом и интересом к конкретным задачам, на которые нацелены.

Однако: вы можете делать все в своем текущем коде без необходимости использования ManualResetEvent - lock в C# - это просто оболочка для частей простейшийMonitor, но Monitor также обеспечивает функциональность ожидания / импульса:

class ProducerConsumerQueue<T>
{
    private readonly Queue<T> Queue = new Queue<T>();

    public void Add(T t)
    {
        lock (Queue)
        {
            Queue.Enqueue(t);
            if (Queue.Count == 1)
            {
                // wake up one sleeper
                Monitor.Pulse(Queue);
            }
        }
    }

    public bool TryTake(out T t, int millisecondsTimeout)
    {
        lock (Queue)
        {
            if (Queue.Count == 0)
            {
                // try and wait for arrival
                Monitor.Wait(Queue, millisecondsTimeout);
            }
            if (Queue.Count != 0)
            {
                t = Queue.Dequeue();
                return true;
            }
        }
        t = default(T);
        return false;
    }
}