.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 }
图片

运行结果如下:

图片

文章来源:

使用Nito.AsyncEx实现异步锁
https://www.cnblogs.com/1zhk/p/5269279.html

Nito.AsyncEx类库实现asp.net ashx 一般处理程序 使用async await异步
https://www.cnblogs.com/sfissw/p/5318316.html

2021-06-22 23:36

阅读原文

简介:我们不生产干货,我们只是干货的搬运工。——阿笨NET 欢迎关注公众号:跟着阿笨一起玩NET
(0)
打赏 喜欢就点个赞支持下吧 喜欢就点个赞支持下吧

声明:本文来自“跟着阿笨一起玩NET”,分享链接:https://www.zyxiao.com/p/323675    侵权投诉

网站客服
网站客服
内容投稿 侵权处理
分享本页
返回顶部