c# - Break parallel.foreach?

multithreading parallel-processing

Question

¿Cómo salgo de un bucle parallel.for ?

Tengo una declaración bastante compleja que se parece a la siguiente:

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

Utilizando la clase paralela, puedo optimizar este proceso por mucho. Sin embargo; No puedo entender cómo romper el bucle paralelo? El break; instrucción arroja el siguiente error de sintaxis:

Sin bucles envolventes para romper o continuar

Answer 1

Lo que debe usar es Any , en lugar de un bucle foreach:

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

Any es lo suficientemente inteligente como para detenerse tan pronto como sepa que el resultado debe ser cierto.

Answer 2

LoopState es sin duda una gran respuesta. Descubrí que las respuestas anteriores tenían tantas otras cosas que era difícil ver la respuesta, así que aquí hay un caso simple:

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

Answer 3

Para ello, llame utilizando la sobrecarga de Parallel.For o Parallel.ForEach que pasa en un estado de bucle, y luego llama a ParallelLoopState.Break o ParallelLoopState.Stop . La principal diferencia radica en cuán rápido se rompen las cosas: con Break() , el ciclo procesará todos los elementos con un "índice" anterior al actual. Con Stop() , saldrá lo más rápido posible.

Para obtener detalles, consulte Cómo detenerse o interrumpirse desde un paralelo . Para bucle .

Answer 4

Simplemente use el loopState que se puede proporcionar.

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

Mira este artículo de MSDN para ver un ejemplo.

Answer 5

Use el método ParallelLoopState.Break :

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

O en tu caso:

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