Làm cách nào để hạn chế số lượng Tác vụ đang hoạt động chạy qua Thư viện tác vụ song song?

Question

Tôi có một số ConcurrentQueue chứa Action (System.Action). Mỗi hành động trong hàng đợi này cần phải chạy (cần được gọi bằng cách sử dụng lời gọi).

Khi hàng đợi không trống => hành động cần được gọi => Nhưng tôi muốn giới hạn số lượng tác vụ song song sẽ chạy. Bên cạnh điều này, một hành động mới có thể được thêm vào hàng đợi bất kỳ lúc nào.

Cách thực hiện?

(sử dụng .net 4.0)

tôi đã viết một cái gì đó nhưng tôi không chắc chắn đây là cách tiếp cận tốt nhất

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

Hãy xem trên Bài viết MSDN How to: Create a Task Scheduler That Limits Concurrency. Bạn có thể sử dụng cách thực hiện LimitedConcurrencyLevelTaskScheduler để làm cho mã của bạn như thế này:

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

Bạn sẽ cần phải xác định ParallelOptions

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

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