c# - 使用 SemaphoreSlim 锁定方法时的奇怪输出

Question

我有一个非常简单的控制台应用程序来测试 SemaphoreSlim 的功能。

class Program
{
    private static readonly ConcurrentDictionary<string, SemaphoreSlim> _locks = new ConcurrentDictionary<string, SemaphoreSlim>();
    private static int _counter = 0;
    static async Task Main(string[] args)
    {
        var tasks = new List<Task>();
        for (var i = 1; i <= 1000; i++)
        {
            tasks.Add(Task.Factory.StartNew(async () => await IncCountWithDictLock("10"))); ;
        }
        await Task.WhenAll(tasks);
        Console.WriteLine(_counter);
    }

    public static async Task IncCountWithDictLock(string userId)
    {
        _locks.TryAdd(userId, new SemaphoreSlim(1, 1));
        var l = _locks[userId];
        var acuireLockRequire = await l.WaitAsync(TimeSpan.FromSeconds(5));
        if (acuireLockRequire)
        {
            _counter++;
            l.Release();
        }
        else
        {
            Console.WriteLine("unable acquire the lock");
        }

    }
}

我希望计数器的结果是 1000，而它是随机的。使用 SemaphoreSlim 时我错过了什么吗？

标签： c#.net.net-core

Answer 1

中的 lambdaTask.Factory.StartNew实际上并没有被等待。查看详情

您可以替换调用方法

tasks.Add(Task.Factory.StartNew(async () => await IncCountWithDictLock("10")))

和

tasks.Add(Task.Run(async () => await IncCountWithDictLock("10")));