Jak ograniczyć liczbę aktywnych zadań uruchomionych za pomocą równoległej biblioteki zadań?

Question

Mam niektóre ConcurrentQueue, które zawierają Action (System.Action). Każda akcja w tej kolejce musi być uruchomiona (trzeba wywołać za pomocą polecenia invoke).

Gdy kolejka nie jest pusta => akcja musi zostać wywołana => Ale chcę wprowadzić ograniczenie liczby zadań równoległych, które będą uruchamiane. Oprócz tego w każdej kolejce można dodać nową akcję.

Jak to zrobić?

(przy użyciu .NET 4.0)

napisałem coś, ale nie na pewno jest to najlepsze podejście

SemaphoreSlim maxThread = new SemaphoreSlim(5); 

while(!actionQueue.IsEmpty) 
     { 
      maxThread.Wait(); 
      Task.Factory.StartNew(() => 
      { 
       Action action; 
       if(actionExecution.TryDequeue(out action)) 
       { 
        action.Invoke(); 
       } 
      }, 
      TaskCreationOptions.LongRunning).ContinueWith((task) => maxThread.Release()); 
     } 
    } 

Answer 1

spojrzeć na Artykuł MSDN How to: Create a Task Scheduler That Limits Concurrency. Możesz użyć z niego implementacji LimitedConcurrencyLevelTaskScheduler, aby utworzyć kod w następujący sposób:

var scheduler = new LimitedConcurrencyLevelTaskScheduler(5); 
TaskFactory factory = new TaskFactory(scheduler); 

while(!actionQueue.IsEmpty) 
{ 
    factory.StartNew(() => 
    { 
     Action action; 
     if(actionExecution.TryDequeue(out action))     
      action.Invoke(); 

    }, TaskCreationOptions.LongRunning); 
} 

Answer 2

Musisz określić ParallelOptions

ParallelOptions options = new ParallelOptions(); 
options.MaxDegreeOfParallelism = 4;//value of your choice 

if (Parallel.ForEach(PDFFiles, options, element => 
{ 
    //do work 
}