c# ReaderWriterLockSlim 实现多线程读取或进行独占式写入访问

鸿翔机器人 · 发表于前天 08:23

internal class Program
{
static void Main(string[] args)
{
Demo02();
Console.ReadLine();
}
static ReaderWriterLockSlim _lockSlim = new ReaderWriterLockSlim();
static Dictionary<int, string> _dic = new Dictionary<int, string>();
static void ReadData(int key)
{
Task.Delay(10000).Wait();
_lockSlim.EnterReadLock();
try
{
if (_dic.TryGetValue(key, out var value))
{
Console.WriteLine($"读取{key}的值为{value}");
}
else
{
Console.WriteLine($"读取{key}失败");
}
}
catch
{
}
finally
{
_lockSlim.ExitReadLock();
}
}
static void WriteData(int key)
{
_lockSlim.EnterWriteLock();
try
{
_dic[key] = DateTime.Now.ToString();
Console.WriteLine($"写入{key}:{_dic[key]}");
}
catch
{
}
finally
{
_lockSlim.ExitWriteLock();
}
}
static void Demo01()
{
new Thread(() => { WriteData(1); }).Start();
new Thread(() => { WriteData(3); }).Start();
new Thread(() => { ReadData(1); }).Start();
new Thread(() => { ReadData(2); }).Start();
new Thread(() => { ReadData(3); }).Start();
}
static bool _isFinsh;
static string _str;
static void ReadTask(int key)
{
while(!_isFinsh)
{
_lockSlim.EnterReadLock();
try
{
Console.WriteLine($"{key}读取:{_str}");
Thread.Sleep(100);
Console.WriteLine($"{key}读取完成:{_str}");
}
catch
{
}
finally
{
_lockSlim.ExitReadLock();
}
}
}
static void WriteTask(int key)
{
while (!_isFinsh)
{
_lockSlim.EnterUpgradeableReadLock();
try
{
if (new Random().NextDouble() > 0.9)
{
_lockSlim.EnterWriteLock();
try
{
_str = DateTime.Now.ToString();
Console.WriteLine($"{key}写入{_str}");
Thread.Sleep(4000);
Console.WriteLine($"{key}写入完成{_str}");
}
catch
{
}
finally
{
_lockSlim.ExitWriteLock();
}
}
}
finally
{
_lockSlim.ExitUpgradeableReadLock();
}
}
}
public static async Task Demo02()
{
for (int i = 0; i < 5; i++)
{
Task.Run(() =>
{
ReadTask(i);
});
}
Task.Run(() => { WriteTask(10); });
await Task.Delay(5000);
_isFinsh = true;
}
}
}

复制代码

c# ReaderWriterLockSlim 实现多线程读取或进行独占式写入访问

浏览过的版块

关于我们

合作伙伴

联系我们