这篇文章将为大家详细讲解有关.NET Core中怎么利用Nito.AsyncEx实现一个异步锁，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。
1、需求描述：
asp.net core在hangfire定时任务中，何为任务并发执行，它代表每一次任务都必须执行完成后，才能开启下一次执行，防止并发执行带来的问题，即也就是防止重复执行。下次任务开始一定要等上一次任务执行完成后才进行。
2、解决办法:
我们可以通过异步锁(async lock)来实现执行出现并发的问题。
3、同步锁和异步锁是什么？
Lock是常用的同步锁，但是我们无法在Lock的内部实现异步调用，比如我们无法使用await。
以下面的代码为例，当你在lock内部使用await时，VS会报错提醒。
最简单的解决办法就是使用第三方的库Nito.AsyncEx。可以通过Nuget安装。
通过AsyncLock就可以在锁的内部实现异步操作了。
样例代码如下：
计算
安全
数据库
网络和加速
企业服务
1 public class AsyncLockDemo 2 { 3 //private readonly object _mutex = new object(); 4 private readonly AsyncLock _mutex = new AsyncLock(); 5 private int i = 0; 6 public void Execute() 7 { 8 Console.WriteLine("before call foo1: "+ i); 9 10 Foo1().ContinueWith(new Action<Task>(t =>11 {12 Console.WriteLine("foo1 completed: " + i);13 }));14 15 Console.WriteLine("after call foo1: " + i);16 17 Console.WriteLine("before call foo2: " + i);18 19 Foo2().ContinueWith(new Action<Task>(t =>20 {21 Console.WriteLine("foo2 completed: " + i);22 }));23 24 Console.WriteLine("after call foo2: " + i);25 }26 27 public async Task Foo1()28 {29 using (await _mutex.LockAsync())30 {31 await Task.Delay(TimeSpan.FromSeconds(1));32 Console.WriteLine("Foo1 start: " + i);33 await DoSomethingAsync(1);34 Console.WriteLine("Foo1 end: " + i);35 }36 }37 38 public async Task Foo2()39 {40 using (await _mutex.LockAsync())41 {42 Console.WriteLine("Foo2 start: " + i);43 //await Task.Delay(TimeSpan.FromSeconds(1));44 await DoSomethingAsync(2);45 Console.WriteLine("Foo2 end: " + i);46 }47 }48 49 private Task DoSomethingAsync(int j)50 {51 return Task<string>.Run(() =>52 {53 Thread.Sleep(2000);54 i = j;55 });56 }57 }
运行结果如下：
关于.NET Core中怎么利用Nito.AsyncEx实现一个异步锁就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/u/4699947/blog/5010834
