在下面的代码上下文中，SemaphoreSlim 的用法是否正确？它会限制最大 运行 个线程吗？

Question

如果我将 maxConcurrency 传递为 10，下面的代码是否会将最大并行任务数限制为 10？如何一次验证任务数 运行？

public BlockingCollection<Task> _workTaskQueue;

public void DequeueTask(int maxConcurrency)
{
    var tasks = new List<Task>();
    using (SemaphoreSlim concurrencySemaphore = new SemaphoreSlim(maxConcurrency))
    {
        foreach (var task in _workTaskQueue.GetConsumingEnumerable())
        {
            concurrencySemaphore.Wait();
            if (!(task.IsCanceled) && task.Status == TaskStatus.Created)
            {
                task.ContinueWith((t) => { concurrencySemaphore.Release(); });
                tasks.Add(task);
                task.Start();
            }
        }
    }
    Task.WaitAll(tasks.ToArray());
}

Answer 1

没有。缺少等待（进入互斥块）的调用。

Answer 2

由于您利用my other answer稍微改变了逻辑，我为您准备了测试代码。 （不需要 var tasks = new List<Task>();）

Random rnd = new Random();
int maxConcurrency = 5;
var _workTaskQueue = new System.Collections.Concurrent.BlockingCollection<Task>();
for (int i = 0; i < 250; i++) 
{
    //Tasks running 250=500ms
    _workTaskQueue.Add(new Task(()=> { Task.Delay(250 + rnd.Next(250)).Wait(); }));
} 
_workTaskQueue.CompleteAdding();
int runningTaks = 0;

using (SemaphoreSlim concurrencySemaphore = new SemaphoreSlim(maxConcurrency))
{
    foreach (var task in _workTaskQueue.GetConsumingEnumerable())
    {
        Console.WriteLine("LoopStart: " + runningTaks);

        await concurrencySemaphore.WaitAsync();

        Console.WriteLine("GotASem  : " + runningTaks);

        task.Start(); 
        Interlocked.Increment(ref runningTaks);
        task.ContinueWith(t =>
            {
                Interlocked.Decrement(ref runningTaks);
                concurrencySemaphore.Release();
            });

        if (runningTaks > maxConcurrency) throw new Exception("ERROR");
        Console.WriteLine("LoopEnd  : " + runningTaks + Environment.NewLine);
    }

    Console.WriteLine("Finalizing: " + runningTaks);
    //Make sure all all tasks have ended.
    for (int i = 0; i < maxConcurrency; i++)
    {
        await concurrencySemaphore.WaitAsync();
    }

    Console.WriteLine("Finished: " + runningTaks);
}