我有多个线程将数据写入一个公共源，我希望两个线程在当且仅当它们接触同一条数据时才相互阻塞。
如果有办法专门锁定任意键就好了：
string id = GetNextId();
AquireLock(id);
try
{
DoDangerousThing();
}
finally
{
ReleaseLock(id);
}
如果没有其他人试图锁定同一个密钥，我希望他们能够同时运行。
我可以通过一个简单的互斥体字典来实现这一点，但我需要担心驱逐旧的、未使用的锁，如果集合变得太大，这可能会成为一个问题。
是否有这种类型的锁定模式的现有实现。
【问题讨论】：
标签： c# synchronization mutex
您可以尝试使用ConcurrentDictionary<string, object> 来创建命名对象实例。当您需要一个新的锁实例（以前没有使用过）时，您可以将它添加到字典中（添加是通过GetOrAdd 进行的原子操作），然后所有线程可以共享同一个命名对象，一旦您从中提取它字典，基于您的数据。
例如：
// Create a global lock map for your lock instances.
public static ConcurrentDictionary<string, object> GlobalLockMap =
new ConcurrentDictionary<string, object> ();
// ...
var oLockInstance = GlobalLockMap.GetOrAdd ( "lock name", x => new object () );
if (oLockInstance == null)
{
// handle error
}
lock (oLockInstance)
{
// do work
}
【讨论】：
lock 关键字 (MSDN) 已经这样做了。
当你锁定时，你传递对象来锁定on：
lock (myLockObject)
{
}
这使用带有特定对象的Monitor 类来同步同一对象上使用lock 的任何线程。
由于字符串字面量是“内部”的——也就是说，它们被缓存以供重用，因此每个具有相同值的字面量实际上都是同一个对象——你也可以对字符串这样做：
lock ("TestString")
{
}
由于您没有处理字符串文字，因此您可以按照以下说明对您读取的字符串进行实习：C#: Strings with same contents。
如果使用的引用是从实习字符串（文字或显式实习）复制（直接或间接），它甚至可以工作。但我不会推荐它。这是非常脆弱的，并且可能导致难以调试的问题，因为可以很容易地创建与实习字符串具有相同值的字符串的新实例。
只有当其他东西进入同一对象上的锁定部分时，锁定才会阻塞。因此，无需保留字典，只需保留适用的锁定对象即可。
但实际上，您需要维护 ConcurrentDictionary 或类似名称以允许您的对象访问适当的锁定对象。
【讨论】：
lock 语句。它太容易损坏或被滥用。在您的第一个提案中坚持使用专用对象是最好的恕我直言。
您可以使用ConcurrentDictionary<string, object> 创建和重用不同的锁。如果您想从字典中删除锁，并在将来重新打开同名资源，您必须始终检查关键区域内部是否先前获取的锁已被其他线程删除或更改。并注意在离开临界区之前的最后步骤从字典中移除锁。
static ConcurrentDictionary<string, object> _lockDict =
new ConcurrentDictionary<string, object>();
// VERSION 1: single-shot method
public void UseAndCloseSpecificResource(string resourceId)
{
bool isSameLock;
object lockObj, lockObjCheck;
do
{
lock (lockObj = _lockDict.GetOrAdd(resourceId, new object()))
{
if (isSameLock = (_lockDict.TryGetValue(resourceId, out lockObjCheck) &&
object.ReferenceEquals(lockObj, lockObjCheck)))
{
// ... open, use, and close resource identified by resourceId ...
// This must be the LAST statement
_lockDict.TryRemove(resourceId, out lockObjCheck);
}
}
}
while (!isSameLock);
}
// VERSION 2: separated "use" and "close" methods
// (can coexist with version 1)
public void UseSpecificResource(string resourceId)
{
bool isSameLock;
object lockObj, lockObjCheck;
do
{
lock (lockObj = _lockDict.GetOrAdd(resourceId, new object()))
{
if (isSameLock = (_lockDict.TryGetValue(resourceId, out lockObjCheck) &&
object.ReferenceEquals(lockObj, lockObjCheck)))
{
// ... open and use (or reuse) resource identified by resourceId ...
}
}
}
while (!isSameLock);
}
public bool TryCloseSpecificResource(string resourceId)
{
bool result = false;
object lockObj, lockObjCheck;
if (_lockDict.TryGetValue(resourceId, out lockObj))
{
lock (lockObj)
{
if (_lockDict.TryGetValue(resourceId, out lockObjCheck) &&
object.ReferenceEquals(lockObj, lockObjCheck))
{
result = true;
// ... close resource identified by resourceId ...
// This must be the LAST statement
_lockDict.TryRemove(resourceId, out lockObjCheck);
}
}
}
return result;
}
【讨论】：