Очереди и дескрипторы ожидания в C#

Для меня это выглядит довольно потокобезопасным, WaitAny() просто завершится немедленно, потому что событие уже установлено. Это не проблема.

Не нарушайте синхронизацию потоков, которая работает. Но если вам нужна лучшая мышеловка, вы можете рассмотреть BlockingQueue Джо Даффи в этом журнальная статья. Более общая версия доступна в .NET 4.0, System.Collections.Concurrent .BlockingCollection с ConcurrentQueue в качестве практической реализации.

Ты прав. Код не является потокобезопасным. Но не по той причине, о которой вы думаете.

AutoResetEvent в порядке. Но только потому, что вы получаете блокировку и повторно тестируете PendingOrders.Count. Настоящая суть вопроса в том, что вы вызываете PendingOrders.Count вне блокировки. Поскольку класс Queue не является потокобезопасным, ваш код не является потокобезопасным... и точка.

Теперь на самом деле у вас, вероятно, никогда не будет проблем с этим по двум причинам. Во-первых, свойство Queue.Count почти наверняка предназначено для того, чтобы никогда не оставлять объект в полусыром состоянии. В конце концов, он, вероятно, просто вернет переменную экземпляра. Во-вторых, отсутствие барьера памяти при чтении не окажет существенного влияния на более широкий контекст вашего кода. Худшее, что может случиться, это то, что вы получите устаревшее чтение на одной итерации цикла, а затем полученная блокировка неявно создаст барьер памяти, и на следующей итерации произойдет новое чтение. Я предполагаю, что в очереди есть только один поток. Все значительно меняется, если их 2 или более.

Однако позвольте мне сделать это совершенно ясно. У вас нет гарантии, что PendingOrders.Count не изменит состояние объекта во время его выполнения. И поскольку он не заблокирован, другой поток может инициировать операцию над ним, пока он все еще находится в этом полузащищенном состоянии.

Использование ручных событий...

ManualResetEvent[] CommandEventArr = new ManualResetEvent[] { NewOrderEvent, ExitEvent };

while ((WaitHandle.WaitAny(CommandEventArr) != 1))
{
    lock (PendingOrders)
    {
        if (PendingOrders.Count > 0)
        {
            fbo = PendingOrders.Dequeue();
        }
        else
        {
            fbo = null;
            NewOrderEvent.Reset();
        }
    }
}

Затем вам также необходимо обеспечить блокировку на стороне очереди:

    lock (PendingOrders)
    {
        PendingOrders.Enqueue(obj);
        NewOrderEvent.Set();
    }

Вы должны использовать WaitAny только для этого и убедиться, что он получает сигнал о каждом новом ордере, добавленном в коллекцию PendingOrders:

while (WaitHandle.WaitAny(CommandEventArr) != 1))
{
   lock (PendingOrders)
   {
      if (PendingOrders.Count > 0)
      {
          fbo = PendingOrders.Dequeue();
      }
      else
      {
          fbo = null;

          //Only if you want to exit when there are no more PendingOrders
          return;
      }
   }

   // Do Some Work if fbo is != null
}