c# – 非空时处理ConcurrentStack？

我有一个ConcurrentStack,我正在倾倒物品.当堆栈不为空时,一次处理这些项目的好方法是什么？我希望这样做的方式是在没有处理堆栈时不占用cpu周期.

我目前得到的基本上是这个,它似乎不是一个理想的解决方案.

private void AddToStack(MyObj obj)
{
    stack.Push(obj);
    HandleStack();
}

private void HandleStack()
{
    if (handling)
        return;

    Task.Run( () =>
    {
        lock (lockObj)
        {
            handling = true;
            if (stack.Any())
            {
                //handle whatever is on top of the stack
            }
            handling = false;
        }
    }
}

所以bool就在那里,因此多个线程不会备份等待锁定.但我不希望一次处理堆栈的多个事情因此锁定.因此,如果两个单独的线程最终同时调用HandleStack并超过bool,则锁定就在那里,因此两者都不会立即迭代堆栈.但是一旦第二次通过锁定,堆栈将是空的并且不会做任何事情.所以这最终会给我我想要的行为.

所以我真的只是在ConcurrentStack周围写一个伪并发包装器,似乎必须采用不同的方法来实现这一点.思考？

解决方法

ConcurrentStack< T>是实现IProducerConsumerCollection< T>的集合之一,因此可以由BlockingCollection< T>包装. BlockingCollection< T>有几个便利成员用于常见操作,例如“在堆栈不为空时消耗”.例如,你可以循环调用TryTake.或者,您可以使用GetConsumingEnumerable：

private BlockingCollection<MyObj> stack;
private Task consumer;

Constructor()
{
  stack = new BlockingCollection<MyObj>(new ConcurrentStack<MyObj>());
  consumer = Task.Run(() =>
  {
    foreach (var myObj in stack.GetConsumingEnumerable())
    {
      ...
    }
  });
}

private void AddToStack(MyObj obj)
{
  stack.Add(obj);
}