Paralelismo de datos (Task Parallel Library)
El paralelismo de datos hace referencia a los escenarios en los que la misma operación se realiza simultáneamente (es decir, en paralelo) en elementos de una colección o matriz de origen. Varias sobrecargas de los métodos ForEach y For admiten el paralelismo de los datos con sintaxis imperativa en la clase System.Threading.Tasks.Parallel. En las operaciones paralelas de datos, se crean particiones de la colección de origen para que varios subprocesos puedan funcionar simultáneamente en segmentos diferentes. TPL admite el paralelismo de datos a través de la clase System.Threading.Tasks.Parallel. Esta clase proporciona las implementaciones paralelas basadas en método de los bucles for y foreach (For y For Each en Visual Basic). Se escribe la lógica del bucle para un bucle Parallel.For o Parallel.ForEach de forma muy similar a como se escribiría un bucle secuencial. No tiene que crear los subprocesos ni poner en la cola los elementos de trabajo. En bucles básicos, no es preciso tomar bloqueos. TPL administra todo el trabajo de bajo nivel. En el siguiente ejemplo de código se muestra un bucle foreach simple y su equivalente paralelo.
.gif "Nota") Nota |
|---|
En esta documentación se utilizan las expresiones lambda para definir los delegados en TPL.Si no está familiarizado con expresiones lambda en C# o Visual Basic, vea Expresiones lambda en PLINQ y TPL. |
' Sequential version
For Each item In sourceCollection
Process(item)
Next
' Parallel equivalent
Parallel.ForEach(sourceCollection, Sub(item) Process(item))
// Sequential version
foreach (var item in sourceCollection)
{
Process(item);
}
// Parallel equivalent
Parallel.ForEach(sourceCollection, item => Process(item));
Cuando un bucle paralelo se ejecuta, la TPL crea particiones del origen de datos para que el bucle pueda funcionar simultáneamente en varias partes. En segundo plano, el programador de tareas crea particiones de la tarea según los recursos del sistema y la carga de trabajo. Cuando es posible, el programador redistribuye el trabajo entre varios subprocesos y procesadores si se desequilibra la carga de trabajo.
| Nota |
|---|
También puede proporcionar un programador o creador de particiones personalizado.Para obtener más información, vea Particionadores personalizados para PLINQ y TPL y Programadores de tareas. |
Los métodos Parallel.ForEach y Parallel.For tienen varias sobrecargas que permiten detener o ejecutar la ejecución de bucles, supervisar el estado del bucle en otros subprocesos, mantener el estado de subprocesos locales, finalizar los objetos de subprocesos locales, controlar el grado de simultaneidad, etc. Los tipos de aplicación auxiliar que habilitan esta funcionalidad son ParallelLoopState, ParallelOptions y ParallelLoopResult, CancellationToken y CancellationTokenSource.
Para obtener más información, vea Paralelismo de datos (Task Parallel Library).
PLINQ admite el paralelismo de datos con sintaxis declarativa o de consulta. Para obtener más información, vea Parallel LINQ (PLINQ).
Temas relacionados
Título |
Descripción |
|---|---|
Describe cómo escribir un bucle For en cualquier matriz o colección de origen IEnumerable<T> indexable. |
|
Describe cómo escribir un bucle ForEach en cualquier colección de origen IEnumerable<T>. |
|
Describe cómo detenerse o salir de un bucle paralelo de forma que todos los subprocesos se informen de la acción. |
|
Cómo: Escribir un bucle Parallel.For que tenga variables locales de subproceso |
Describe cómo escribir un bucle For en el que cada subproceso mantiene una variable privada que no está visible para cualquier otro subproceso y cómo sincronizar los resultados de todos los subprocesos cuando el bucle se completa. |
Cómo: Escribir un bucle Parallel.ForEach que tenga variables locales de subproceso |
Describe cómo escribir un bucle ForEach en el que cada subproceso mantiene una variable privada que no está visible para cualquier otro subproceso y cómo sincronizar los resultados de todos los subprocesos cuando el bucle se completa. |
Describe cómo cancelar un bucle paralelo utilizando un System.Threading.CancellationToken |
|
Describe una manera de acelerar la ejecución cuando el cuerpo de un bucle es muy pequeño. |
|
Proporciona información general sobre Task Parallel Library. |
|
Presenta la programación paralela en .NET Framework. |