我有一个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< 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); }