Wie kann die Anzahl der aktiven Aufgaben begrenzt werden, die über die Parallel Task Library ausgeführt werden?

Question

Ich habe einige ConcurrentQueue die Aktion enthalten (System.Action). Jede Aktion in dieser Warteschlange muss ausgeführt werden (muss mit invoke aufgerufen werden).

Wenn die Warteschlange nicht leer ist => müssen die zu ergreifenden aufrufen => Aber ich möchte einige Begrenzung für die Anzahl der parallelen Aufgabe machen, die ausgeführt wird. Darüber hinaus kann jederzeit eine neue Aktion zur Warteschlange hinzugefügt werden.

Wie geht das?

(mit .net 4.0)

ich etwas geschrieben, aber ich nicht sicher, dies ist der beste Ansatz

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

Werfen Sie einen Blick auf angeben MSDN-Artikel How to: Create a Task Scheduler That Limits Concurrency. Sie können LimitedConcurrencyLevelTaskScheduler Implementierung davon verwenden, um Ihren Code wie folgt zu machen:

Answer 2

Sie müssen ParallelOptions

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

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