提问者:小点点

使用SemaphoreSlim锁定方法时出现奇怪的输出


我有一个非常简单的控制台应用程序来测试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时遗漏了什么吗?


共1个答案

匿名用户

task.factory.StartNew中的lambda实际上没有被等待。 请参阅详细信息

您可以替换调用方法

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

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