Sample of a method that throttles concurrent work to avoid flooding the threadpool queue

ThrottleParallelWork.cs

Task ThrottleParallelWorkAsync(IEnumerable<T> data, Action<T> worker)
{
  TaskScheduler scheduler = new ConcurrentExclusiveSchedulerPair(
    TaskScheduler.Default,          // schedule work to the ThreadPool
    Environment.ProcessorCount * 2) // Schedule enough to keep all threads busy, with a queue to quickly replace completed work
    .ConcurrentScheduler;           // We only use the concurrent member of this scheduler "pair".
    
  return Task.WhenAll(
    data.Select(v => Task.Factory.StartNew(() => worker(v), CancellationToken.None, TaskCreationOptions.None, scheduler)));
}