Przerwij równolegle. Przed?

Jak wyjść z pętli parallel.for ?

Mam dość złożone oświadczenie, które wygląda następująco:

Parallel.ForEach<ColorIndexHolder>(ColorIndex.AsEnumerable(),
    new Action<ColorIndexHolder>((ColorIndexHolder Element) =>
    {
        if (Element.StartIndex <= I && Element.StartIndex + Element.Length >= I)
        {
            Found = true;
            break;
        }
    }));

Korzystając z klasy równoległej, mogę zdecydowanie zoptymalizować ten proces. Jednak; Nie mogę dowiedzieć się, jak przerwać pętlę równoległą? break;Oświadczenie wyrzuca następujący błąd składni:

Żadnych otaczających pętli, z których można by przerwać lub kontynuować

Użyj ParallelLoopState.Breakmetody:

 Parallel.ForEach(list,
    (i, state) =>
    {
       state.Break();
    });

Lub w twoim przypadku:

Parallel.ForEach<ColorIndexHolder>(ColorIndex.AsEnumerable(),
    new Action<ColorIndexHolder, ParallelLoopState>((ColorIndexHolder Element, ParallelLoopState state) =>
    {
        if (Element.StartIndex <= I && Element.StartIndex + Element.Length >= I)
        {
            Found = true;
            state.Break();
        }
    }));

Robisz to, wywołując przy użyciu przeciążenia Parallel.Forlub, Parallel.ForEachktóre przechodzi w stanie pętli, a następnie wywołując ParallelLoopState.Breaklub ParallelLoopState.Stop. Główna różnica polega na tym, jak szybko wszystko się psuje - Break()pętla przetworzy wszystkie elementy z wcześniejszym „indeksem” niż bieżący. Po użyciu Stop()wyjdzie tak szybko, jak to możliwe.

Aby uzyskać szczegółowe informacje, zobacz How to: Stop or Break from a Parallel.For Loop .

Powinieneś używać Anyzamiast pętli foreach:

bool Found = ColorIndex.AsEnumerable().AsParallel()
    .Any(Element => Element.StartIndex <= I 
      && Element.StartIndex + Element.Length >= I);

Any jest na tyle sprytny, że zatrzymuje się, gdy tylko wie, że wynik musi być prawdziwy.

LoopState to z pewnością świetna odpowiedź. Zauważyłem, że poprzednie odpowiedzi miały tak wiele innych rzeczy, że trudno było znaleźć odpowiedź, więc oto prosty przypadek:

using System.Threading.Tasks;

Parallel.ForEach(SomeTable.Rows(), (row, loopState) =>
{
    if (row.Value == testValue)
    {
        loopState.Stop();  // Stop the ForEach!
    }       
    // else do some other stuff here.
});

Po prostu użyj tego, loopStateco może być dostarczone.

Parallel.ForEach<ColorIndexHolder>(ColorIndex.AsEnumerable(),  
    new Action<ColorIndexHolder>((Element, loopState) => { 
        if (Element.StartIndex <= I && Element.StartIndex + Element.Length >= I) { 
            loopState.Stop();
        }     
})); 

Spójrz na przykład w tym artykule MSDN .