189 8069 5689
这篇文章将为大家详细讲解有关.NET Core中怎么利用Nito.AsyncEx实现一个异步锁，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。
成都创新互联专业为企业提供盐边网站建设、盐边做网站、盐边网站设计、盐边网站制作等企业网站建设、网页设计与制作、盐边企业网站模板建站服务，10余年盐边做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。
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(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(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.Run(() =>
52 {
53 Thread.Sleep(2000);
54 i = j;
55 });
56 }
57 }
运行结果如下：
关于.NET Core中怎么利用Nito.AsyncEx实现一个异步锁就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。