无法安全锁定 ConcurrentDictionary 的值

我在锁定集合中的项目时遇到问题 - 特别是 ConcurrentDictionary。

我需要接受一条消息，在字典中查找该消息，然后对其进行长时间的扫描。由于程序占用大量内存，扫描后对象返回true如果他们认为现在是删除它的好时机（我通过将其从词典中删除来做到这一点）。但是，另一个线程可能会在相似的时间出现并尝试在删除后立即访问同一对象。这是我的第一次尝试：

string dictionaryKey = myMessage.someValue;

DictionaryObject currentObject = myConcurrentDictionary.GetOrAdd(dictionaryKey, new DictionaryObject());
// we can be interrupted here
lock (currentObject)
{
    //KeyNotFoundException is possible on line below
    if (myConcurrentDictionary[dictonaryKey].scan(myMessage)) // Scans the message - returns true if the object says its OK to remove it from the dictionary
    {
      DictionaryObject temp;                      //   It's OK to delete it
      if (!queuedMessages.TryRemove(ric, out temp))   // Did delete work?
       throw new Exception("Was unable to delete a DictionaryObject that just reported it was ok to delete it");
    }
}

但是，上述方法不起作用 - 一个线程可能会在另一个线程尝试访问字典中的对象之前从字典中删除该对象。读完之后lock 是 Monitor.Enter 和 Monitor.Exit 的简写 http://www.albahari.com/threading/part2.aspx#_Locking，我尝试过这个：

string dictionaryKey = myMessage.someValue;
Monitor.Enter(GetDictionaryLocker);
DictionaryObject currentObject = myConcurrentDictionary.GetOrAdd(dictionaryKey, new DictionaryObject());
// we can be interrupted here
lock (currentObject)
{
    Monitor.Exit(GetDictionaryLocker);
    //KeyNotFoundException is still possible on line below
    if (myConcurrentDictionary[dictonaryKey].scan(myMessage)) // Scans the message - returns true if the object says its OK to remove it from the dictionary
    {
      DictionaryObject temp;                   //   It's OK to delete it
      if (!queuedMessages.TryRemove(ric, out temp))   // Did delete work?
       throw new Exception("Was unable to delete a DictionaryObject that just reported it was ok to delete it");
    }
}

两种方式都可能导致密钥未找到异常当尝试在字典中查找对象时。

有谁知道我如何找到我想要锁定的对象，然后在不被中断的情况下锁定它？抱歉 - 我是并发新手，感到非常困惑！

Thanks,

Frederik

您应该在开始扫描之前从字典中删除该对象，以防止任何其他线程尝试同时使用它。如果以后需要的话，在失败后，您可以随时将其添加回来scan()。在此并发集合上，删除和添加都保证是线程安全的。

这应该使你想要的成为可能，无需任何locks or Monitor usage.

string dictionaryKey = myMessage.someValue;

DictionaryObject currentObject = null;
if (myConcurrentDictionary.TryRemove(dictionaryKey, out currentObject))
{
    //KeyNotFoundException is possible on line below
    if (!currentObject.scan(myMessage)) // Scans the message - returns true if the object says its OK to remove it from the dictionary
    {
      if (!myConcurrentDictionary.TryAdd(dictionaryKey, currentObject))
       throw new Exception("Was unable to re-insert a DictionaryObject that is not OK for deletion");
    }
} 

我对此的担忧是，在不了解代码的其余部分的情况下，其他线程是否可以在调用期间使用相同的密钥添加回另一条消息scan()。这会导致TryAdd失败。如果有可能，则需要做更多的工作。

当前模型的问题在于，即使集合是线程安全的，如果您希望将“正在扫描”的项目留在集合中，您真正必须做的是执行以下操作组合原子地： 1. 找到免费项目并 2. 将其标记为“正在使用”。

1. 可以凭借集合的线程安全性来完成，但是
2. 必须单独完成，所以你打开一个窗口用于多个scan()s 在同一个对象上。