同时出列一个项目

Question

假设我们有两个线程使用下面执行的方法：

while(true){

    if(Queue.Count() <= 0){
        wait();
    }

    object anObject = Queue.Dequeue();
}

现在问题出现在 Queue 有一个元素 init 时，线程 1 即将执行 Queue.Count 行，线程 2 大约在 Queue.Dequeue() 上，执行优先级在线程 1 上。

当这种情况发生时，线程 1 将抛出异常，因为 Queue.Count() 将返回 1 并尝试从空队列中取出对象。我该如何处理？如果我想安全地出队，最好的解决方案是什么？我应该使用同步还是锁定某些东西？

最好的问候， 凯末尔

Answer 1

假设您使用的是 .NET 4.0 或更高版本并且确实需要队列，最好的解决方案是切换到使用 ConcurrentQueue 并且它是 TryDequeue 方法。 ConcurrentQueue 是线程安全的。

也就是说，从您的代码 sn-p 来看，您真正在寻找的是一个线程安全的生产者/消费者队列。在这种情况下，请使用 BlockingCollection 类，它是 Take 方法：

while(true){
    // This will block until an item becomes available to take.
    // It is also thread safe, and can be called by multiple 
    // threads simultaneously. When an item is added, only one
    // waiting thread will Take() it
    object anObject = myBlockingCollection.Take();

    // do something with anObject
}

Answer 2

您可以使用线程安全队列ConcurrentQueue。

或者如果你不想使用它

    while (true)
    {
        Monitor.Enter(lockObj);
        try
        {
            if (Queue.Count <= 0)
            {
                Monitor.Wait(lockObj);
            }

            object anObject = Queue.Dequeue();
        }
        finally
        {
            Monitor.Exit(lockObj);
        }
    }

或者如果使用lock

    while (true)
    {
        lock(lockObj)
        {
            if (Queue.Count <= 0)
            {
                Monitor.Wait(lockObj);
            }

            object anObject = Queue.Dequeue();
        }
    }

Answer 3

试试这个模式：

制片人

public void Produce(object o)
{
  lock (_queueLock)
  {
    _queue.Enqueue(o);
    Monitor.Pulse(_queueLock);
  }
}

消费者

public object Consume()
{
  lock (_queueLock)
  {
    while (_queue.Count==0)
    {
      Monitor.Wait(_queueLock);
    }
    return _queue.Dequeue();
  }
}

Answer 4

在访问之前锁定队列。

lock (Queue) {
    // blah blah
}

编辑

while(true){
    lock (Queue) {
        if (Queue.Count() > 0) {
            // Dequeue only if there is still something in the queue
            object anObject = Queue.Dequeue();
        }
    }     
}