使用并发堆栈

Question

我需要使用栈数据结构来保存字符串。但是这个栈会被多个线程访问。所以我的问题是，如何使用 ConcurrentStack 从多个线程添加数据？

Answer 1

线程使用：

_stack.Push(obj);

在另一个线程上使用：

MyObj obj;    
if (_stack.TryPop(out obj))
    UseObj(obj);

我推荐阅读this MSDN blog post。

Answer 2

到目前为止，您已经收到了一些不错的答案。让我提供一些有关其设计的有用信息，以帮助您更好地了解如何使用它。请注意，没有 Pop 方法。那是因为设计者想要阻止您执行以下不安全的操作序列。这是不安全的，因为调用Count 属性和假设的Pop 方法的顺序不是原子的，尽管集合被称为线程安全的。

while (stack.Count > 0)
{
  stack.Pop();
}

为了协调这个常见的用例，设计师改用了TryPop 方法。这基本上允许您像下面这样重写上面的内容。这次代码是安全的。

object item;
while (stack.TryPop(out item))
{
  // Do something with the item here.
}

Push 方法也存在我的第一个示例的推论。下面的代码（这次是合法的）也是不安全的。

if (stack.Count < MAX_ITEMS)
{
  stack.Push(...);
}

后一个示例不像前一个示例那样常见，这可能是设计人员没有添加类似CAS 的等效操作TryPush 的原因。也许在将来的版本中将提供给我们。

Answer 3

从多个线程向ConcurrentStack 添加值相当简单。只需引用可用的堆栈并从需要添加数据的任何线程调用Push。这里不需要特殊的锁定，因为集合旨在以这种方式从多个线程中使用。

Answer 4

您创建您的ConcurrentStack<string>，并确保所有线程都引用它。

然后线程将调用Push 来添加字符串：

theStack.Push("foo");

Answer 5

恭喜，您为多线程使用选择了正确的容器。整个类都是线程安全的，建议用于您的场景，因此请酌情使用Push 或PushRange。

范围示例代码here 使用并行化来演示多线程操作。