.net core WebApi ManualResetEvent实现并发同步
2021-07-09 01:08
标签：ram img finally 代码 inf json ati soft cal ManualResetEvent，即手动重置事件，通过信号量来判别当前线程是否应该阻塞或继续执行。使用方式与ManualResetEventSlim差不多，ManualResetEventSlim只是针对ManualResetEvent轻量化的使用。 一、在控制台应用程序中测试 请看如下代码： 结果如下图所示： 测试结果和预期一样。 二、在webapi项目中测试 代码如下： 接下来，我们连续发送8次请求，看看结果如何： 由结果可以看到，多个线程中，只有一个线程操作成功，起到了并发同步的目的。 注意：信号量事件(ManualResetEvent)对象要用同一个的WaitOne、Reset和Set配合才会实现并发同步的效果。 如果是轻量化的线程间同步操作，建议用ManualResetEventSlim。其效果和ManualResetEvent是一样的，可以去看看我的《.net core WebApi Interlocked配合ManualResetEventSlim实现并发同步》这篇随笔。 .net core WebApi ManualResetEvent实现并发同步 标签：ram img finally 代码 inf json ati soft cal 原文地址：https://www.cnblogs.com/williamwsj/p/9722976.htmlprivate static ManualResetEvent mre = new ManualResetEvent(true);
static void Main(string[] args)
{
//释放信号量
mre.Reset();
for (int i = 0; i 3; i++)
{
Thread t = new Thread(ManualSubFuncTest);
t.Name = $"Thread.{i}";
t.Start();
}
Thread.SpinWait(10);
Console.WriteLine("all threads have started,please waiting for 3 seconds...");
Thread.Sleep(3000);
//获取信号量
mre.Set();
Console.ReadKey();
}
static void ManualSubFuncTest()
{
string name = Thread.CurrentThread.Name;
Console.WriteLine($"{name} starts and calling waitone() method " );
//如果mre不拥有信号量，则等待，否则继续执行
mre.WaitOne();
Console.WriteLine($"{name} ends");
}
[HttpGet("[controller]/v1/api/[action]")]
public IActionResult Test() {
return Json(SynchronizationTest());
}
protected static int Counter = 1;//1:空闲 0:非空闲
protected static ManualResetEvent Mre=new ManualResetEvent(false);
public ResponseModel SynchronizationTest() {
ResponseModel rc = new ResponseModel(0, "初始化");
try
{
Mre.Reset();
//如果其他线程正在操作，则等待，5秒后超时
if (Interlocked.CompareExchange(ref Counter, 0, 1) == 0)
Mre.WaitOne(3000);
int count = RedisHelper.Get(GoodsNumberKey).ToInt32();
if (count > 0) {
RedisHelper.Set(GoodsNumberKey, "-1");
rc.SetMessage("重置成功！");
}
else rc.SetMessage("已被重置，本次重置无效");
}
catch (Exception ex) {
_log.Error(ex);
}
finally {
//转为空闲状态
Interlocked.Exchange(ref Counter, 1);
//设置信号量，让上面的 Mre.Wait(3000);取消等待，继续执行代码
Mre.Set();
}
return rc;
}
文章标题：.net core WebApi ManualResetEvent实现并发同步
文章链接：http://soscw.com/index.php/essay/102562.html