Разрыв parallel.foreach?

Как мне выйти из цикла parallel.for ?

У меня есть довольно сложное утверждение, которое выглядит следующим образом:

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

Используя параллельный класс, я могу значительно оптимизировать этот процесс. Тем не мение; Не могу понять, как разорвать параллельный цикл? Этот break;оператор выдает следующую синтаксическую ошибку:

Нет замыкающих петель, из которых можно было бы разорвать или продолжить

Используйте ParallelLoopState.Breakметод:

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

Или в вашем случае:

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();
        }
    }));

Вы делаете это, вызывая с помощью перегрузки Parallel.Forили, Parallel.ForEachкоторая переходит в состояние цикла, а затем вызываяParallelLoopState.Break или ParallelLoopState.Stop. Основное различие заключается в том, как быстро все прерывается - Break()цикл будет обрабатывать все элементы с более ранним "индексом", чем текущий. С Stop(), он выйдет как можно быстрее.

Дополнительные сведения см. В разделе Практическое руководство. Остановить параллельный цикл или выйти из него .

Вы должны использовать Any, а не цикл foreach:

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

Any достаточно умен, чтобы остановиться, как только узнает, что результат должен быть верным.

LoopState, безусловно, отличный ответ. Я обнаружил, что в предыдущих ответах было так много другого материала, что было трудно увидеть ответ, поэтому вот простой случай:

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.
});

Просто используйте то, loopStateчто может быть предоставлено.

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

Взгляните на эту статью MSDN для примера.