class Program
{
static void Main(string[] args)
{
var c = ReadWriteLockDemo.GetValue("value", x =>
{
Console.WriteLine(x);
return x;
});
Console.WriteLine("结束了");
Console.WriteLine($@"获取到的结果为:{c}");
}
}
public static class ReadWriteLockSimpleDemo
{
private static ReaderWriterLockSlim _lock = new ReaderWriterLockSlim();
private static int _countA = 0;
public static int _countB = 0;
/// <summary>
/// 增加
/// </summary>
public static void IncrementCounters()
{
_lock.EnterWriteLock();
try
{
++_countA;
++_countB;
}
finally
{
_lock.ExitWriteLock();
}
}
/// <summary>
/// 获取
/// </summary>
/// <param name="countA"></param>
/// <param name="countB"></param>
public static void GetCounters(ref int countA, ref int countB)
{
_lock.EnterReadLock();
try
{
countA = _countA;
countB = _countB;
}
finally
{
_lock.ExitReadLock();
}
}
}
升级版
public static class ReadWriteLockDemo
{
private static ReaderWriterLockSlim _lock = new ReaderWriterLockSlim();
private static Dictionary<string, string> _dict = new Dictionary<string, string>();
public static string GetValue(string key, Func<string, string> factory)
{
_lock.EnterUpgradeableReadLock();
try
{
//值已生成时可以直接返回
if (_dict.TryGetValue(key, out var value))
{
return value;
}
//获取(升级到)写入锁
_lock.EnterWriteLock();
try
{
//再次判断值是否已生成
if (!_dict.TryGetValue(key, out value))
{
value = factory(key);
_dict.Add(key, value);
}
return value;
}
finally
{
//释放写入锁
_lock.ExitWriteLock();
}
}
finally
{
//释放读取锁
_lock.ExitUpgradeableReadLock();
}
}
}