równoległe ForEach i kolejki

Question

jest to możliwe, że równolegle do każdego procesu pętli elementy w kolejce, tak że:

1. usuwa jedynie elementy, które są przetwarzane
2. Wstrzymuje aż nowe elementy są dodawane do kolejki

EDIT: to jest w odniesieniu do funkcjonalności Parallel.ForEach System.Threading.Tasks'

Answer 1

Zapisz się do kolejki przy użyciu Reactive Extensions i wykonać każdy element w nowym zadaniu. Nie będziesz musiał blokować ani czekać na nowy produkt, ponieważ zostanie on przekazany do Twojej subskrypcji lambda, a twoje wykonanie/przetwarzanie będzie równoległe.

http://rxwiki.wikidot.com/101samples

Answer 2

myślę, że byłoby to możliwe, jeśli kolejka beton REALIZACJA nacja jest zsynchronizowana, zasadniczo jest to scenariusz konsumencko-producencki.

Answer 3

To brzmi jak mówisz klasycznym producenta/sytuacji konsumentów. Zawsze zaskakuje mnie, że nie ma bezpośredniego wsparcia dla tego modelu wbudowanego w .Net. Najbliższe, z jakimi spotkałem się w .Net, było kiedyś ukryte w środowisku wykonawczym współbieżności i koordynacji, które było częścią pakietu Microsoft Robotics. Powodzenia, znajdź to teraz.

Ale gdy wiesz, czego szukać, szybkie sprawdzenie Google robi podać kilka innych potencjalnych możliwości.

Answer 4

Zastosowanie BlockingCollection coś takiego:

var bc = new BlockingCollection<int>(); 
Task.Factory.StartNew(() => 
    { 
     ParallelOptions options = new ParallelOptions 
      { 
       MaxDegreeOfParallelism = 30 
      }; 
     Parallel.ForEach(bc.GetConsumingEnumerable(), options, i => { }); 
    });