tests/DotNetCommon.Test/AsyncLockerTests.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using DotNetCommon.Data;
using DotNetCommon.Extensions;
using NUnit.Framework;
using Shouldly;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace DotNetCommon.Test
{
    [TestFixture]
    internal class AsyncLockerTests
    {
        [Test]
        public void Test()
        {
            HttpClient httpClient = new HttpClient();
            //判断加不加锁  通过对比 current 在http请求前后是否相等
            var current = 0;
            var tasks = new List<Task>();
            var res = new List<(int k, bool success)>();
            for (int i = 0; i < 10; i++)
            {
                var k = i;
                tasks.Add(Task.Run(async () =>
                {
                    //加锁的
                    await AsyncLocker.LockAsync("123", async () =>
                    {
                        current = k;
                        Console.WriteLine($"{DateTime.Now.ToCommonString()} Thread:{Thread.CurrentThread.ManagedThreadId} {k} start...");
                        var str = await httpClient.GetStringAsync("http://www.baidu.com");
                        Console.WriteLine($"{DateTime.Now.ToCommonString()} Thread:{Thread.CurrentThread.ManagedThreadId} {k} end...");
                        res.Add((k, current == k));
                    });
                    //不加锁的 
                    //current = k;
                    //Console.WriteLine($"{DateTime.Now.ToCommonString()} Thread:{Thread.CurrentThread.ManagedThreadId} {k} start...");
                    //var str = await httpClient.GetStringAsync("http://www.baidu.com");
                    //Console.WriteLine($"{DateTime.Now.ToCommonString()} Thread:{Thread.CurrentThread.ManagedThreadId} {k} end...");
                    //res.Add((k, current == k));
                }));
            }
            Task.WaitAll(tasks.ToArray());
            res.ForEach(i => i.success.ShouldBeTrue());
        }

        [Test]
        public void TestReturn()
        {
            HttpClient httpClient = new HttpClient();
            //判断加不加锁  通过对比 current 在http请求前后是否相等
            var current = 0;
            var tasks = new List<Task>();
            var res = new List<(int k, bool success)>();
            for (int i = 0; i < 10; i++)