我有一个非常简单的控制台应用程序来测试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时遗漏了什么吗?
task.factory.StartNew
中的lambda实际上没有被等待。 请参阅详细信息
您可以替换调用方法
tasks.Add(Task.Factory.StartNew(async () => await IncCountWithDictLock("10")))
与
tasks.Add(Task.Run(async () => await IncCountWithDictLock("10")));